Package | Description |
---|---|
org.apache.flink.table.planner.plan.nodes.exec | |
org.apache.flink.table.planner.plan.nodes.exec.serde |
Modifier and Type | Class and Description |
---|---|
static class |
ExecEdge.HashShuffle
Records are shuffled by hash when passing through this edge.
|
Modifier and Type | Field and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
ExecEdge.Shuffle |
ExecEdge.getShuffle() |
static ExecEdge.Shuffle |
ExecEdge.hashShuffle(int[] keys)
Return hash
ExecEdge.Shuffle . |
Modifier and Type | Method and Description |
---|---|
ExecEdge.Builder |
ExecEdge.Builder.shuffle(ExecEdge.Shuffle shuffle) |
Constructor and Description |
---|
ExecEdge(ExecNode<?> source,
ExecNode<?> target,
ExecEdge.Shuffle shuffle,
ShuffleMode shuffleMode) |
Modifier and Type | Method and Description |
---|---|
ExecEdge.Shuffle |
ShuffleJsonDeserializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser jsonParser,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext ctx) |
ExecEdge.Shuffle |
ExecNodeGraphJsonPlanGenerator.JsonPlanEdge.getShuffle() |
Modifier and Type | Method and Description |
---|---|
void |
ShuffleJsonSerializer.serialize(ExecEdge.Shuffle shuffle,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator jsonGenerator,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.SerializerProvider serializerProvider) |
Constructor and Description |
---|
JsonPlanEdge(int sourceId,
int targetId,
ExecEdge.Shuffle shuffle,
ShuffleMode shuffleMode) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.