Package | Description |
---|---|
org.apache.flink.streaming.runtime.partitioner |
Modifier and Type | Class and Description |
---|---|
class |
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.
|
class |
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) method for details). |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.