| Interface | Description |
|---|---|
| BulkReceiver |
Receiver for multiple values
|
| DataFlowOperation |
The communication operation interface.
|
| DestinationSelector |
Destination selector interface needs to be implemented when creating destination selection
logic.
|
| ReduceFunction |
Functions that are used for reduce operations have to be implementations of this interface.
|
| SingularReceiver |
Interface for receiving a single value.
|
| Class | Description |
|---|---|
| BaseOperation | |
| CommunicationContext | |
| Communicator |
Communicator that keeps the information about.
|
| EdgeGenerator | |
| LogicalPlan |
Information about the instances in which the communication happens.
|
| TaskIdGenerator |
Task ids
|
| Enum | Description |
|---|---|
| CommunicationContext.JoinAlgorithm | |
| CommunicationContext.JoinType | |
| Op |
The reduce operation supported by default on the primitive arrays
|