org.apache.flink.table.planner.plan.nodes.exec.common

Class CommonExecExchange

java.lang.Object

org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase<RowData>

org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecExchange

All Implemented Interfaces:

ExecNode<RowData>, ExecNodeTranslator<RowData>, SingleTransformationTranslator<RowData>

Direct Known Subclasses:

BatchExecExchange, StreamExecExchange

public abstract class CommonExecExchange
extends ExecNodeBase<RowData>
implements SingleTransformationTranslator<RowData>

Base class for exec Exchange.

TODO Remove this class once its functionality is replaced by ExecEdge.

Field Summary

Fields inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNode

FIELD_NAME_CONFIGURATION, FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE, FIELD_NAME_TYPE

Constructor Summary

Constructors

Constructor and Description
CommonExecExchange(int id, ExecNodeContext context, ReadableConfig persistedConfig, List<InputProperty> inputProperties, RowType outputType, String description)

Method Summary

Methods inherited from class org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase

accept, createFormattedTransformationDescription, createFormattedTransformationName, createTransformationDescription, createTransformationMeta, createTransformationMeta, createTransformationName, createTransformationUid, getContextFromAnnotation, getDescription, getId, getInputEdges, getInputProperties, getOutputType, getPersistedConfig, getSimplifiedName, getTransformation, inputsContainSingleton, replaceInputEdge, resetTransformation, setCompiled, setInputEdges, translateToPlan, translateToPlanInternal

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNodeTranslator

translateToPlan

Constructor Detail

CommonExecExchange

public CommonExecExchange(int id,
                          ExecNodeContext context,
                          ReadableConfig persistedConfig,
                          List<InputProperty> inputProperties,
                          RowType outputType,
                          String description)