Class ExecEdge.Shuffle
- java.lang.Object
-
- org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.Shuffle
-
- Direct Known Subclasses:
ExecEdge.HashShuffle
- Enclosing class:
- ExecEdge
public abstract static class ExecEdge.Shuffle extends Object
TheExecEdge.Shuffle
defines how to exchange the records betweenExecNode
s.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ExecEdge.Shuffle.Type
Enumeration which describes the shuffle type for records when passing this edge.
-
Constructor Summary
Constructors Modifier Constructor Description protected
Shuffle(ExecEdge.Shuffle.Type type)
-
-
-
Constructor Detail
-
Shuffle
protected Shuffle(ExecEdge.Shuffle.Type type)
-
-
Method Detail
-
getType
public ExecEdge.Shuffle.Type getType()
-
-