| Class | Description |
|---|---|
| CoGroupOperator |
An operator for cogroup.
|
| CrossOperator |
An operator for cross/cartesian/all-pairs.
|
| DataSink |
An operator for writing data.
|
| DataSource |
An operator for reading data.
|
| FileDataSink |
A data sink that writes to files.
|
| FileDataSource |
A data sink that reads from files.
|
| JoinOperator |
An operator for match/join.
|
| MapOperator |
An operator for map.
|
| NullSink |
A data sink that does not write to anything.
|
| Operator |
A base class for operators in a Spark job.
|
| ReduceOperator |
An operator for reduce.
|
| TokenSink |
A data sink that writes to Ptolemy tokens.
|
| TokenSource |
An data source that reads Ptolemy tokens.
|