|
Operator Classes
We currently support three classes of operators based on their input and output behavior.
Unary: Unary operators are operators that accept a single input stream and generate a single output stream, e.g., filter, map.
Nary: Nary operators accept multiple input streams and generate a single output stream ( all with the same or distinct schemas), e.g., join, merge.
Exchange Operator: Exchange operators accept a single input stream and are responsible for generating multiple output streams, e.g., broadcast, and keyBy.
|