类的使用
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.Shuffle

使用ExecEdge.Shuffle的程序包

程序包	说明
org.apache.flink.table.planner.plan.nodes.exec

org.apache.flink.table.planner.plan.nodes.exec中ExecEdge.Shuffle的使用

org.apache.flink.table.planner.plan.nodes.exec中ExecEdge.Shuffle的子类

限定符和类型	类和说明
static class	ExecEdge.HashShuffle Records are shuffled by hash when passing through this edge.

声明为ExecEdge.Shuffle的org.apache.flink.table.planner.plan.nodes.exec中的字段

限定符和类型	字段和说明
static ExecEdge.Shuffle	ExecEdge.ANY_SHUFFLE Any type of shuffle is OK when passing through this edge.
static ExecEdge.Shuffle	ExecEdge.BROADCAST_SHUFFLE Full records are provided for each parallelism of the target node.
static ExecEdge.Shuffle	ExecEdge.FORWARD_SHUFFLE Records are shuffled in same parallelism (function call).
static ExecEdge.Shuffle	ExecEdge.SINGLETON_SHUFFLE The parallelism of the target node must be 1.

返回ExecEdge.Shuffle的org.apache.flink.table.planner.plan.nodes.exec中的方法

限定符和类型	方法和说明
ExecEdge.Shuffle	ExecEdge.getShuffle()
static ExecEdge.Shuffle	ExecEdge.hashShuffle(int[] keys) Return hash ExecEdge.Shuffle.

参数类型为ExecEdge.Shuffle的org.apache.flink.table.planner.plan.nodes.exec中的方法

限定符和类型	方法和说明
ExecEdge.Builder	ExecEdge.Builder.shuffle(ExecEdge.Shuffle shuffle)

参数类型为ExecEdge.Shuffle的org.apache.flink.table.planner.plan.nodes.exec中的构造器

构造器和说明
ExecEdge(ExecNode<?> source, ExecNode<?> target, ExecEdge.Shuffle shuffle, org.apache.flink.streaming.api.transformations.StreamExchangeMode exchangeMode)