Class Hierarchy
- java.lang.Object
- org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase<T> (implements org.apache.flink.table.planner.plan.nodes.exec.ExecNode<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecBoundedStreamScan (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.MultipleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecHashAggregate (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecHashJoin (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecHashWindowAggregate (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecLimit (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecMultipleInput (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNestedLoopJoin (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecOverAggregateBase (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecPythonGroupAggregate (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecPythonGroupWindowAggregate (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecRank (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecSort (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecSortAggregate (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecSortLimit (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecSortMergeJoin (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecSortWindowAggregate (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecCalc (implements org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecCalc (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>)
- org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecCorrelate (implements org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecExchange (implements org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecExchange (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>)
- org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecExpand (implements org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecExpand (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>)
- org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecLegacySink<T> (implements org.apache.flink.table.planner.plan.nodes.exec.MultipleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecLegacyTableSourceScan (implements org.apache.flink.table.planner.plan.nodes.exec.MultipleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecLookupJoin (implements org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecPythonCalc (implements org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecPythonCorrelate (implements org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink (implements org.apache.flink.table.planner.plan.nodes.exec.MultipleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecSink (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>)
- org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan (implements org.apache.flink.table.planner.plan.nodes.exec.MultipleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecUnion (implements org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecUnion (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>)
- org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecValues (implements org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecValues (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>)
Interface Hierarchy
- org.apache.flink.table.planner.plan.nodes.exec.ExecNodeTranslator<T>
- org.apache.flink.table.planner.plan.nodes.exec.ExecNode<T>
- org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>
Enum Hierarchy
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.