Modifier and Type | Method and Description |
---|---|
ShuffleMode |
StreamEdge.getShuffleMode() |
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.addVirtualPartitionNode(Integer originalId,
Integer virtualId,
StreamPartitioner<?> partitioner,
ShuffleMode shuffleMode)
Adds a new virtual node that is used to connect a downstream vertex to an input with a
certain partitioning.
|
Constructor and Description |
---|
StreamEdge(StreamNode sourceVertex,
StreamNode targetVertex,
int typeNumber,
long bufferTimeout,
StreamPartitioner<?> outputPartitioner,
OutputTag outputTag,
ShuffleMode shuffleMode,
int uniqueId) |
StreamEdge(StreamNode sourceVertex,
StreamNode targetVertex,
int typeNumber,
StreamPartitioner<?> outputPartitioner,
OutputTag outputTag,
ShuffleMode shuffleMode,
int uniqueId) |
Modifier and Type | Method and Description |
---|---|
ShuffleMode |
PartitionTransformation.getShuffleMode()
Returns the
ShuffleMode of this PartitionTransformation . |
static ShuffleMode |
ShuffleMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ShuffleMode[] |
ShuffleMode.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
PartitionTransformation(Transformation<T> input,
StreamPartitioner<T> partitioner,
ShuffleMode shuffleMode)
Creates a new
PartitionTransformation from the given input and StreamPartitioner . |
Modifier and Type | Method and Description |
---|---|
ShuffleMode |
ExecEdge.getShuffleMode() |
Modifier and Type | Method and Description |
---|---|
ExecEdge.Builder |
ExecEdge.Builder.shuffleMode(ShuffleMode shuffleMode) |
Constructor and Description |
---|
ExecEdge(ExecNode<?> source,
ExecNode<?> target,
ExecEdge.Shuffle shuffle,
ShuffleMode shuffleMode) |
Modifier and Type | Method and Description |
---|---|
static ShuffleMode |
BatchExecExchange.getShuffleMode(Configuration config,
ShuffleMode requiredShuffleMode) |
Modifier and Type | Method and Description |
---|---|
Optional<ShuffleMode> |
BatchExecExchange.getRequiredShuffleMode() |
Modifier and Type | Method and Description |
---|---|
static ShuffleMode |
BatchExecExchange.getShuffleMode(Configuration config,
ShuffleMode requiredShuffleMode) |
void |
BatchExecExchange.setRequiredShuffleMode(ShuffleMode requiredShuffleMode) |
Constructor and Description |
---|
InputPriorityConflictResolver(List<ExecNode<?>> roots,
InputProperty.DamBehavior safeDamBehavior,
ShuffleMode shuffleMode,
Configuration configuration)
Create a
InputPriorityConflictResolver for the given ExecNode graph. |
Modifier and Type | Method and Description |
---|---|
ShuffleMode |
ExecNodeGraphJsonPlanGenerator.JsonPlanEdge.getShuffleMode() |
Constructor and Description |
---|
JsonPlanEdge(int sourceId,
int targetId,
ExecEdge.Shuffle shuffle,
ShuffleMode shuffleMode) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.