Modifier and Type | Method and Description |
---|---|
StreamExchangeMode |
StreamEdge.getExchangeMode() |
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.addVirtualPartitionNode(Integer originalId,
Integer virtualId,
StreamPartitioner<?> partitioner,
StreamExchangeMode exchangeMode)
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,
StreamExchangeMode exchangeMode,
int uniqueId) |
StreamEdge(StreamNode sourceVertex,
StreamNode targetVertex,
int typeNumber,
StreamPartitioner<?> outputPartitioner,
OutputTag outputTag,
StreamExchangeMode exchangeMode,
int uniqueId) |
Modifier and Type | Method and Description |
---|---|
StreamExchangeMode |
PartitionTransformation.getExchangeMode()
Returns the
StreamExchangeMode of this PartitionTransformation . |
static StreamExchangeMode |
StreamExchangeMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static StreamExchangeMode[] |
StreamExchangeMode.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,
StreamExchangeMode exchangeMode)
Creates a new
PartitionTransformation from the given input and StreamPartitioner . |
Modifier and Type | Method and Description |
---|---|
StreamExchangeMode |
ExecEdge.getExchangeMode() |
Modifier and Type | Method and Description |
---|---|
ExecEdge.Builder |
ExecEdge.Builder.exchangeMode(StreamExchangeMode exchangeMode) |
Constructor and Description |
---|
ExecEdge(ExecNode<?> source,
ExecNode<?> target,
ExecEdge.Shuffle shuffle,
StreamExchangeMode exchangeMode) |
Modifier and Type | Method and Description |
---|---|
Optional<StreamExchangeMode> |
BatchExecExchange.getRequiredExchangeMode() |
Modifier and Type | Method and Description |
---|---|
void |
BatchExecExchange.setRequiredExchangeMode(StreamExchangeMode requiredExchangeMode) |
Constructor and Description |
---|
InputPriorityConflictResolver(List<ExecNode<?>> roots,
InputProperty.DamBehavior safeDamBehavior,
StreamExchangeMode exchangeMode,
ReadableConfig tableConfig)
Create a
InputPriorityConflictResolver for the given ExecNode graph. |
Modifier and Type | Method and Description |
---|---|
static StreamExchangeMode |
StreamExchangeModeUtils.getBatchStreamExchangeMode(ReadableConfig config,
StreamExchangeMode requiredExchangeMode) |
Modifier and Type | Method and Description |
---|---|
static StreamExchangeMode |
StreamExchangeModeUtils.getBatchStreamExchangeMode(ReadableConfig config,
StreamExchangeMode requiredExchangeMode) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.