📄️ Projection Operator
The Projection Operator implements the Project relation defined in substrait. The Projection operator is stateless and does not need to store any state.
📄️ Filter Operator
The Filter Operator implements the Filter relation defined in substrait. The Filter operator is stateless and does not need to store any state.
📄️ Join Operators
Join in Flowtide is implemented with two different operators, a block-nested join operator, and a merge-join operator.
📄️ Normalization Operator
The Normalization Operator is used mostly as a helper operator for ingestion of data.
📄️ Set Operator
The Set Operator can take in 2->N inputs and will perform a set operation on the inputs. At this point only UNION ALL is supported by the set operator.
📄️ Aggregate Operator
The Aggregate Operator implements the Substrait Aggregate Relation.
📄️ Iteration Operator
The iteration operator allows a user to do to iterative streams, such as a recursive join in a tree structure.
📄️ Buffer Operator
The buffer operator collects all events that happens in between watermarks and stores them in a temporary tree.
📄️ Top N Operator
The Top N Operator implements the Top N Relation defined in substrait.
📄️ Table Function Operator
The table function operator(s) execute different table functions.