| BroadcastPartitioner<T> |
Partitioner that selects all the output channels.
|
| CustomPartitionerWrapper<K,T> |
Partitioner that selects the channel with a user defined partitioner function on a key.
|
| ForwardForConsecutiveHashPartitioner<T> |
If there are multiple consecutive and the same hash shuffles, SQL planner will change them except
the first one to use forward partitioner, so that these operators can be chained to reduce
unnecessary shuffles.
|
| ForwardForUnspecifiedPartitioner<T> |
|
| ForwardPartitioner<T> |
Partitioner that forwards elements only to the locally running downstream operation.
|
| GlobalPartitioner<T> |
Partitioner that sends all elements to the downstream operator with subtask ID=0.
|
| KeyGroupStreamPartitioner<T,K> |
Partitioner selects the target channel based on the key group index.
|
| RebalancePartitioner<T> |
Partitioner that distributes the data equally by cycling through the output channels.
|
| RescalePartitioner<T> |
Partitioner that distributes the data equally by cycling through the output channels.
|
| ShufflePartitioner<T> |
Partitioner that distributes the data equally by selecting one output channel randomly.
|
| StreamPartitioner<T> |
|