public class BatchExecExchange extends CommonExecExchange implements BatchExecNode<RowData>
ExecNode
represents a change of partitioning of the input elements for batch.
TODO Remove this class once FLINK-21224 is finished.
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
BatchExecExchange(InputProperty inputProperty,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
String |
getDescription()
Returns a string which describes this node.
|
Optional<ShuffleMode> |
getRequiredShuffleMode() |
static ShuffleMode |
getShuffleMode(Configuration config,
ShuffleMode requiredShuffleMode) |
void |
setRequiredShuffleMode(ShuffleMode requiredShuffleMode) |
protected Transformation<RowData> |
translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
Internal method, translates this node into a Flink operator.
|
accept, getId, getInputEdges, getInputProperties, getNewNodeId, getOutputType, inputsContainSingleton, replaceInputEdge, resetIdCounter, setInputEdges, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setInputEdges
translateToPlan
public BatchExecExchange(InputProperty inputProperty, RowType outputType, String description)
public void setRequiredShuffleMode(@Nullable ShuffleMode requiredShuffleMode)
public String getDescription()
ExecNode
getDescription
in interface ExecNode<RowData>
getDescription
in class ExecNodeBase<RowData>
protected Transformation<RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
ExecNodeBase
translateToPlanInternal
in class ExecNodeBase<RowData>
public static ShuffleMode getShuffleMode(Configuration config, @Nullable ShuffleMode requiredShuffleMode)
@VisibleForTesting public Optional<ShuffleMode> getRequiredShuffleMode()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.