Uses of Class
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeConfig

Packages that use ExecNodeConfig

Package	Description
org.apache.flink.table.planner.plan.nodes.exec
org.apache.flink.table.planner.plan.nodes.exec.batch
org.apache.flink.table.planner.plan.nodes.exec.batch.runtimefilter
org.apache.flink.table.planner.plan.nodes.exec.common
org.apache.flink.table.planner.plan.nodes.exec.stream
org.apache.flink.table.planner.plan.utils

Uses of ExecNodeConfig in org.apache.flink.table.planner.plan.nodes.exec

Methods in org.apache.flink.table.planner.plan.nodes.exec that return ExecNodeConfig

Modifier and Type	Method and Description
static ExecNodeConfig	ExecNodeConfig.ofNodeConfig(org.apache.flink.configuration.ReadableConfig nodeConfig, boolean isCompiled)
static ExecNodeConfig	ExecNodeConfig.ofTableConfig(org.apache.flink.table.api.TableConfig tableConfig, boolean isCompiled)

Methods in org.apache.flink.table.planner.plan.nodes.exec with parameters of type ExecNodeConfig

Modifier and Type	Method and Description
protected TransformationMetadata	ExecNodeBase.createTransformationMeta(String operatorName, ExecNodeConfig config)
protected TransformationMetadata	ExecNodeBase.createTransformationMeta(String operatorName, String detailName, String simplifiedName, ExecNodeConfig config)
protected String	ExecNodeBase.createTransformationUid(String operatorName, ExecNodeConfig config)
String	ExecNodeContext.generateUid(String transformationName, ExecNodeConfig config) Returns a new uid for transformations.
static List<Long>	StateMetadata.getStateTtlForMultiInputOperator(ExecNodeConfig config, int inputNumOfOperator, List<StateMetadata> stateMetadataList)
static long	StateMetadata.getStateTtlForOneInputOperator(ExecNodeConfig config, List<StateMetadata> stateMetadataList)
protected OpFusionCodegenSpecGenerator	ExecNodeBase.translateToFusionCodegenSpecInternal(PlannerBase planner, ExecNodeConfig config, CodeGeneratorContext parentCtx) Internal method, translates this node into a operator codegen spec generator.
protected abstract org.apache.flink.api.dag.Transformation<T>	ExecNodeBase.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config) Internal method, translates this node into a Flink operator.

Uses of ExecNodeConfig in org.apache.flink.table.planner.plan.nodes.exec.batch

Methods in org.apache.flink.table.planner.plan.nodes.exec.batch with parameters of type ExecNodeConfig

Modifier and Type	Method and Description
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecSink.applyUpsertMaterialize(org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransform, int[] primaryKeys, int sinkParallelism, ExecNodeConfig config, ClassLoader classLoader, org.apache.flink.table.types.logical.RowType physicalRowType, int[] inputUpsertKey)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecLegacyTableSourceScan.createConversionTransformationIfNeeded(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment streamExecEnv, ExecNodeConfig config, ClassLoader classLoader, org.apache.flink.api.dag.Transformation<?> sourceTransform, org.apache.calcite.rex.RexNode rowtimeExpression)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecLookupJoin.createSyncLookupJoinWithState(org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, org.apache.flink.table.functions.TableFunction<?> syncLookupFunction, RelBuilder relBuilder, org.apache.flink.table.types.logical.RowType inputRowType, org.apache.flink.table.types.logical.RowType tableSourceRowType, org.apache.flink.table.types.logical.RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)
protected OpFusionCodegenSpecGenerator	BatchExecCalc.translateToFusionCodegenSpecInternal(PlannerBase planner, ExecNodeConfig config, CodeGeneratorContext parentCtx)
protected OpFusionCodegenSpecGenerator	BatchExecHashAggregate.translateToFusionCodegenSpecInternal(PlannerBase planner, ExecNodeConfig config, CodeGeneratorContext parentCtx)
protected OpFusionCodegenSpecGenerator	BatchExecExecutionOrderEnforcer.translateToFusionCodegenSpecInternal(PlannerBase planner, ExecNodeConfig config, CodeGeneratorContext parentCtx)
protected OpFusionCodegenSpecGenerator	BatchExecHashJoin.translateToFusionCodegenSpecInternal(PlannerBase planner, ExecNodeConfig config, CodeGeneratorContext parentCtx)
protected OpFusionCodegenSpecGenerator	BatchExecInputAdapter.translateToFusionCodegenSpecInternal(PlannerBase planner, ExecNodeConfig config, CodeGeneratorContext parentCtx)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecNestedLoopJoin.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<Object>	BatchExecSink.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecSortAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecExchange.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecOverAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<Object>	BatchExecDynamicFilteringDataCollector.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecLimit.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecHashAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecBoundedStreamScan.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecLegacyTableSourceScan.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecExecutionOrderEnforcer.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecRank.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecHashWindowAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecSort.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecValues.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecHashJoin.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecPythonGroupAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecPythonGroupWindowAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecScriptTransform.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecSortLimit.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecLookupJoin.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecSortWindowAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecInputAdapter.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecWindowTableFunction.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecMultipleInput.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecSortMergeJoin.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecTableSourceScan.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecPythonOverAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecWindowTableFunction.translateWithUnalignedWindow(PlannerBase planner, ExecNodeConfig config, org.apache.flink.table.types.logical.RowType inputRowType, org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransform)

Uses of ExecNodeConfig in org.apache.flink.table.planner.plan.nodes.exec.batch.runtimefilter

Methods in org.apache.flink.table.planner.plan.nodes.exec.batch.runtimefilter with parameters of type ExecNodeConfig

Modifier and Type	Method and Description
protected OpFusionCodegenSpecGenerator	BatchExecRuntimeFilter.translateToFusionCodegenSpecInternal(PlannerBase planner, ExecNodeConfig config, CodeGeneratorContext parentCtx)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecLocalRuntimeFilterBuilder.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecGlobalRuntimeFilterBuilder.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	BatchExecRuntimeFilter.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)

Uses of ExecNodeConfig in org.apache.flink.table.planner.plan.nodes.exec.common

Methods in org.apache.flink.table.planner.plan.nodes.exec.common with parameters of type ExecNodeConfig

Modifier and Type	Method and Description
protected abstract org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecSink.applyUpsertMaterialize(org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransform, int[] primaryKeys, int sinkParallelism, ExecNodeConfig config, ClassLoader classLoader, org.apache.flink.table.types.logical.RowType physicalRowType, int[] inputUpsertKey)
protected abstract org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecLegacyTableSourceScan.createConversionTransformationIfNeeded(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment streamExecEnv, ExecNodeConfig config, ClassLoader classLoader, org.apache.flink.api.dag.Transformation<?> sourceTransform, org.apache.calcite.rex.RexNode rowtimeExpression)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecLookupJoin.createJoinTransformation(PlannerBase planner, ExecNodeConfig config, boolean upsertMaterialize, boolean lookupKeyContainsPrimaryKey)
protected org.apache.flink.api.dag.Transformation<Object>	CommonExecSink.createSinkTransformation(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment streamExecEnv, ExecNodeConfig config, ClassLoader classLoader, org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransform, org.apache.flink.table.connector.sink.DynamicTableSink tableSink, int rowtimeFieldIndex, boolean upsertMaterialize, int[] inputUpsertKey)
protected org.apache.flink.streaming.api.functions.ProcessFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>	CommonExecLookupJoin.createSyncLookupJoinFunction(org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, org.apache.flink.table.functions.TableFunction<?> syncLookupFunction, RelBuilder relBuilder, org.apache.flink.table.types.logical.RowType inputRowType, org.apache.flink.table.types.logical.RowType tableSourceRowType, org.apache.flink.table.types.logical.RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled)
protected abstract org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecLookupJoin.createSyncLookupJoinWithState(org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, org.apache.flink.table.functions.TableFunction<?> syncLookupFunction, RelBuilder relBuilder, org.apache.flink.table.types.logical.RowType inputRowType, org.apache.flink.table.types.logical.RowType tableSourceRowType, org.apache.flink.table.types.logical.RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecMatch.translateOrder(org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransform, org.apache.flink.table.types.logical.RowType inputRowType, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecPythonCorrelate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<T>	CommonExecLegacySink.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecTableSourceScan.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecMatch.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecValues.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecExpand.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecWindowTableFunction.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecAsyncCalc.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecCalc.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecCorrelate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecLegacyTableSourceScan.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecUnion.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecPythonCalc.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected abstract org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecWindowTableFunction.translateWithUnalignedWindow(PlannerBase planner, ExecNodeConfig config, org.apache.flink.table.types.logical.RowType inputRowType, org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransform)

Uses of ExecNodeConfig in org.apache.flink.table.planner.plan.nodes.exec.stream

Methods in org.apache.flink.table.planner.plan.nodes.exec.stream with parameters of type ExecNodeConfig

Modifier and Type	Method and Description
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecSink.applyUpsertMaterialize(org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransform, int[] primaryKeys, int sinkParallelism, ExecNodeConfig config, ClassLoader classLoader, org.apache.flink.table.types.logical.RowType physicalRowType, int[] inputUpsertKey)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecLegacyTableSourceScan.createConversionTransformationIfNeeded(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment streamExecEnv, ExecNodeConfig config, ClassLoader classLoader, org.apache.flink.api.dag.Transformation<?> sourceTransform, org.apache.calcite.rex.RexNode rowtimeExpression)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecLookupJoin.createSyncLookupJoinWithState(org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, org.apache.flink.table.functions.TableFunction<?> syncLookupFunction, RelBuilder relBuilder, org.apache.flink.table.types.logical.RowType inputRowType, org.apache.flink.table.types.logical.RowType tableSourceRowType, org.apache.flink.table.types.logical.RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)
org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecMatch.translateOrder(org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransform, org.apache.flink.table.types.logical.RowType inputRowType, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecJoin.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecLocalWindowAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecSort.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecWindowRank.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecGroupTableAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecOverAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecDataStreamScan.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecMiniBatchAssigner.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecWindowJoin.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecLimit.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecSortLimit.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecRank.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecGlobalGroupAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecPythonGroupTableAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecWatermarkAssigner.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<Object>	StreamExecSink.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecIntervalJoin.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecLookupJoin.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecDropUpdateBefore.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecGroupAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecTemporalSort.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecTemporalJoin.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecWindowAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecPythonGroupAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecGroupWindowAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecExchange.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecWindowDeduplicate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecChangelogNormalize.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecGlobalWindowAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecIncrementalGroupAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecPythonGroupWindowAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecDeduplicate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecPythonOverAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecLocalGroupAggregate.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecMultipleInput.translateToPlanInternal(PlannerBase planner, ExecNodeConfig config)
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	StreamExecWindowTableFunction.translateWithUnalignedWindow(PlannerBase planner, ExecNodeConfig config, org.apache.flink.table.types.logical.RowType inputRowType, org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransform)

Uses of ExecNodeConfig in org.apache.flink.table.planner.plan.utils

Methods in org.apache.flink.table.planner.plan.utils with parameters of type ExecNodeConfig

Modifier and Type	Method and Description
static AsyncUtil.Options	AsyncUtil.getAsyncOptions(ExecNodeConfig config) Gets the options required to run the operator.
static org.apache.flink.table.runtime.operators.join.SortMergeJoinFunction	SorMergeJoinOperatorUtil.getSortMergeJoinFunction(ClassLoader classLoader, ExecNodeConfig config, org.apache.flink.table.runtime.operators.join.FlinkJoinType joinType, org.apache.flink.table.types.logical.RowType leftType, org.apache.flink.table.types.logical.RowType rightType, int[] leftKeys, int[] rightKeys, org.apache.flink.table.types.logical.RowType keyType, boolean leftIsSmaller, boolean[] filterNulls, org.apache.flink.table.runtime.generated.GeneratedJoinCondition condFunc, double externalBufferMemRatio)