Class ExecEdge.HashShuffle
- java.lang.Object
-
- org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.Shuffle
-
- org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.HashShuffle
-
- Enclosing class:
- ExecEdge
public static class ExecEdge.HashShuffle extends ExecEdge.Shuffle
Records are shuffled by hash when passing through this edge.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.Shuffle
ExecEdge.Shuffle.Type
-
-
Constructor Summary
Constructors Constructor Description HashShuffle(int[] keys)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int[]
getKeys()
String
toString()
-
Methods inherited from class org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.Shuffle
getType
-
-
-
-
Method Detail
-
getKeys
public int[] getKeys()
-
toString
public String toString()
- Overrides:
toString
in classExecEdge.Shuffle
-
-