public class ExecEdge extends Object
ExecNode
s.
The edge's json serialization/deserialization will be delegated to ExecNodeGraphJsonPlanGenerator.JsonPlanEdge
, which
only stores the ExecNode
's id instead of instance.
ExecNodeGraphJsonPlanGenerator.JsonPlanEdge
should also be updated with this class if the fields are added/removed.
Modifier and Type | Class and Description |
---|---|
static class |
ExecEdge.Builder
Builder of the
ExecEdge . |
static class |
ExecEdge.HashShuffle
Records are shuffled by hash when passing through this edge.
|
static class |
ExecEdge.Shuffle
The
ExecEdge.Shuffle defines how to exchange the records between ExecNode s. |
Modifier and Type | Field and Description |
---|---|
static ExecEdge.Shuffle |
ANY_SHUFFLE
Any type of shuffle is OK when passing through this edge.
|
static ExecEdge.Shuffle |
BROADCAST_SHUFFLE
Full records are provided for each parallelism of the target node.
|
static ExecEdge.Shuffle |
FORWARD_SHUFFLE
Records are shuffled in same parallelism (function call).
|
static ExecEdge.Shuffle |
SINGLETON_SHUFFLE
The parallelism of the target node must be 1.
|
Constructor and Description |
---|
ExecEdge(ExecNode<?> source,
ExecNode<?> target,
ExecEdge.Shuffle shuffle,
ShuffleMode shuffleMode) |
Modifier and Type | Method and Description |
---|---|
static ExecEdge.Builder |
builder() |
LogicalType |
getOutputType()
Returns the output
LogicalType of the data passing this edge. |
ExecEdge.Shuffle |
getShuffle() |
ShuffleMode |
getShuffleMode() |
ExecNode<?> |
getSource() |
ExecNode<?> |
getTarget() |
static ExecEdge.Shuffle |
hashShuffle(int[] keys)
Return hash
ExecEdge.Shuffle . |
String |
toString() |
Transformation<?> |
translateToPlan(Planner planner)
Translates this edge into a Flink operator.
|
public static final ExecEdge.Shuffle ANY_SHUFFLE
public static final ExecEdge.Shuffle BROADCAST_SHUFFLE
public static final ExecEdge.Shuffle SINGLETON_SHUFFLE
public static final ExecEdge.Shuffle FORWARD_SHUFFLE
public ExecEdge(ExecNode<?> source, ExecNode<?> target, ExecEdge.Shuffle shuffle, ShuffleMode shuffleMode)
public ExecNode<?> getSource()
public ExecNode<?> getTarget()
public ExecEdge.Shuffle getShuffle()
public ShuffleMode getShuffleMode()
public LogicalType getOutputType()
LogicalType
of the data passing this edge.public static ExecEdge.Builder builder()
public static ExecEdge.Shuffle hashShuffle(int[] keys)
ExecEdge.Shuffle
.keys
- hash keyspublic Transformation<?> translateToPlan(Planner planner)
planner
- The Planner
of the translated Table.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.