Hierarchy For Package org.apache.flink.table.planner.plan.nodes.exec.batch

Package Hierarchies:

• All Packages

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.BatchExecDynamicFilteringDataCollector (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>)
    • org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecExecutionOrderEnforcer (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<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.BatchExecInputAdapter (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.SingleTransformationTranslator<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.SingleTransformationTranslator<T>)
    • org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecOverAggregateBase (implements org.apache.flink.table.planner.plan.nodes.exec.batch.InputSortedExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
      • org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecOverAggregate
      • org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecPythonOverAggregate
    • 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.InputSortedExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
    • org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecScriptTransform (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.BatchExecSort (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.BatchExecSortAggregate (implements org.apache.flink.table.planner.plan.nodes.exec.batch.InputSortedExecNode<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.InputSortedExecNode<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.batch.BatchExecCorrelate (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<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.batch.BatchExecLegacySink<T> (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<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.batch.BatchExecLegacyTableSourceScan (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>)
    • org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecLookupJoin
      • org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecLookupJoin (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.CommonExecMatch (implements org.apache.flink.table.planner.plan.nodes.exec.ExecNode<T>, org.apache.flink.table.planner.plan.nodes.exec.MultipleTransformationTranslator<T>)
      • org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecMatch (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.common.CommonExecPythonCalc (implements org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTranslator<T>)
      • org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecPythonCalc (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<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.batch.BatchExecPythonCorrelate (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<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.batch.BatchExecTableSourceScan (implements org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<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>)
    • org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecWindowTableFunction (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.BatchExecWindowTableFunction (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> (also extends org.apache.flink.table.planner.plan.nodes.exec.FusionCodegenExecNode)
    • org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>
      • org.apache.flink.table.planner.plan.nodes.exec.batch.InputSortedExecNode<T>
• org.apache.flink.table.planner.plan.nodes.exec.FusionCodegenExecNode
  • org.apache.flink.table.planner.plan.nodes.exec.ExecNode<T> (also extends org.apache.flink.table.planner.plan.nodes.exec.ExecNodeTranslator<T>)
    • org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecNode<T>
      • org.apache.flink.table.planner.plan.nodes.exec.batch.InputSortedExecNode<T>

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecOverAggregateBase.OverWindowMode