Interface | Description |
---|---|
ConfigurableStreamPartitioner |
Interface for
StreamPartitioner which have to be configured with the maximum parallelism
of the stream transformation. |
Class | Description |
---|---|
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> |
When the parallelism of both upstream and downstream is
ExecutionConfig.PARALLELISM_DEFAULT and the edge's partitioner is not specified
(partitioner==null), the edge's partitioner will be set to FORWARD by default(See StreamGraph.createActualEdge(java.lang.Integer, java.lang.Integer, int, org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<?>, org.apache.flink.util.OutputTag, org.apache.flink.streaming.api.transformations.StreamExchangeMode, org.apache.flink.runtime.jobgraph.IntermediateDataSetID) method for details). |
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> |
A special
ChannelSelector for use in streaming programs. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.