| Class | Description |
|---|---|
| BaseComputeOp<I> |
takes care of preparing the compute instances and creating the
MultiEdgeOpAdapter |
| BaseOp |
Every tset op is a Receptor.
|
| CheckpointedSourceOp<T> | |
| ComputeCollectorOp<O,I> |
Performs the compute function on the value received for the imessage and write it to edges
|
| ComputeCollectorToTupleOp<K,O,I> | |
| ComputeOp<O,I> |
Performs the compute function on the value received for the imessage and write it to edges
|
| ComputeToTupleOp<K,O,I> | |
| KeyedSourceOp<K,V> |
Identical to
SourceOp. |
| MultiEdgeOpAdapter | |
| SinkOp<T> |
Creates a sink using
SinkFunc. |
| SourceOp<T> | |
| WindowComputeOp<O,I> |