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

接口 ExecNodeTranslator<T>

类型参数:

T - The type of the elements that result from this translator.

所有已知子接口:

BatchExecNode<T>, ExecNode<T>, InputSortedExecNode<T>, MultipleTransformationTranslator<T>, SingleTransformationTranslator<T>, StreamExecNode<T>

所有已知实现类:

BatchExecBoundedStreamScan, BatchExecCalc, BatchExecCorrelate, BatchExecExchange, BatchExecExpand, BatchExecHashAggregate, BatchExecHashJoin, BatchExecHashWindowAggregate, BatchExecLegacySink, BatchExecLegacyTableSourceScan, BatchExecLimit, BatchExecLookupJoin, BatchExecMultipleInput, BatchExecNestedLoopJoin, BatchExecOverAggregate, BatchExecOverAggregateBase, BatchExecPythonCalc, BatchExecPythonCorrelate, BatchExecPythonGroupAggregate, BatchExecPythonGroupWindowAggregate, BatchExecPythonOverAggregate, BatchExecRank, BatchExecSink, BatchExecSort, BatchExecSortAggregate, BatchExecSortLimit, BatchExecSortMergeJoin, BatchExecSortWindowAggregate, BatchExecTableSourceScan, BatchExecUnion, BatchExecValues, BatchExecWindowTableFunction, CommonExecCalc, CommonExecCorrelate, CommonExecExchange, CommonExecExpand, CommonExecLegacySink, CommonExecLegacyTableSourceScan, CommonExecLookupJoin, CommonExecPythonCalc, CommonExecPythonCorrelate, CommonExecSink, CommonExecTableSourceScan, CommonExecUnion, CommonExecValues, CommonExecWindowTableFunction, ExecNodeBase, StreamExecAggregateBase, StreamExecCalc, StreamExecChangelogNormalize, StreamExecCorrelate, StreamExecDataStreamScan, StreamExecDeduplicate, StreamExecDropUpdateBefore, StreamExecExchange, StreamExecExpand, StreamExecGlobalGroupAggregate, StreamExecGlobalWindowAggregate, StreamExecGroupAggregate, StreamExecGroupTableAggregate, StreamExecGroupWindowAggregate, StreamExecIncrementalGroupAggregate, StreamExecIntervalJoin, StreamExecJoin, StreamExecLegacySink, StreamExecLegacyTableSourceScan, StreamExecLimit, StreamExecLocalGroupAggregate, StreamExecLocalWindowAggregate, StreamExecLookupJoin, StreamExecMatch, StreamExecMiniBatchAssigner, StreamExecMultipleInput, StreamExecOverAggregate, StreamExecPythonCalc, StreamExecPythonCorrelate, StreamExecPythonGroupAggregate, StreamExecPythonGroupTableAggregate, StreamExecPythonGroupWindowAggregate, StreamExecPythonOverAggregate, StreamExecRank, StreamExecSink, StreamExecSort, StreamExecSortLimit, StreamExecTableSourceScan, StreamExecTemporalJoin, StreamExecTemporalSort, StreamExecUnion, StreamExecValues, StreamExecWatermarkAssigner, StreamExecWindowAggregate, StreamExecWindowAggregateBase, StreamExecWindowDeduplicate, StreamExecWindowJoin, StreamExecWindowRank, StreamExecWindowTableFunction

@Internal
public interface ExecNodeTranslator<T>

An ExecNodeTranslator is responsible for translating an ExecNode to Transformations.

方法概要

限定符和类型	方法和说明
org.apache.flink.api.dag.Transformation<T>	translateToPlan(org.apache.flink.table.delegation.Planner planner) Translates this node into a Transformation.

方法详细资料

translateToPlan

org.apache.flink.api.dag.Transformation<T> translateToPlan(org.apache.flink.table.delegation.Planner planner)

Translates this node into a Transformation.

NOTE: This method should return same translate result if called multiple times.

参数:

planner - The Planner of the translated Table.