public class BatchExecMultipleInput extends ExecNodeBase<RowData> implements BatchExecNode<RowData>, SingleTransformationTranslator<RowData>
ExecNode
for multiple input which contains a sub-graph of ExecNode
s. The
root node of the sub-graph is rootNode
, and the leaf nodes of the sub-graph are the
output nodes of the #getInputNodes()
.
The following example shows a graph of ExecNode
s with multiple input node:
Sink
|
+---------+--------+
| | |
| Join |
| / \ | BatchExecMultipleInput
| Agg1 Agg2 |
| | | |
+----+-------+-----+
| |
Exchange1 Exchange2
| |
Scan1 Scan2
The multiple input node contains three nodes: `Join`, `Agg1` and `Agg2`. `Join` is the root
node (rootNode
) of the sub-graph, `Agg1` and `Agg2` are the leaf nodes of the sub-graph,
`Exchange1` and `Exchange2` are the input nodes of the multiple input node.
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
BatchExecMultipleInput(List<InputProperty> inputProperties,
ExecNode<?> rootNode,
String description) |
Modifier and Type | Method and Description |
---|---|
protected Transformation<RowData> |
translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
Internal method, translates this node into a Flink operator.
|
accept, getDescription, getId, getInputEdges, getInputProperties, getNewNodeId, getOutputType, inputsContainSingleton, replaceInputEdge, resetIdCounter, setInputEdges, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setInputEdges
translateToPlan
public BatchExecMultipleInput(List<InputProperty> inputProperties, ExecNode<?> rootNode, String description)
protected Transformation<RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
ExecNodeBase
translateToPlanInternal
in class ExecNodeBase<RowData>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.