| 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) |
| 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(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx)
Internal method, translates this node into a operator codegen spec generator.
|
protected abstract org.apache.flink.api.dag.Transformation<T> |
ExecNodeBase.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config)
Internal method, translates this node into a Flink operator.
|
| 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 |
BatchExecExecutionOrderEnforcer.translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx) |
protected OpFusionCodegenSpecGenerator |
BatchExecHashJoin.translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx) |
protected OpFusionCodegenSpecGenerator |
BatchExecHashAggregate.translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx) |
protected OpFusionCodegenSpecGenerator |
BatchExecCalc.translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx) |
protected OpFusionCodegenSpecGenerator |
BatchExecInputAdapter.translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecOverAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecExecutionOrderEnforcer.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecLimit.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecWindowTableFunction.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecHashJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<Object> |
BatchExecSink.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecMultipleInput.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecPythonOverAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecTableSourceScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecLegacyTableSourceScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecSort.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecSortWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecSortAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecSortLimit.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecRank.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecHashWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecSortMergeJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecValues.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<Object> |
BatchExecDynamicFilteringDataCollector.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecHashAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecNestedLoopJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecExchange.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecPythonGroupWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecScriptTransform.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecLookupJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecInputAdapter.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecBoundedStreamScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecPythonGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecWindowTableFunction.translateWithUnalignedWindow(org.apache.flink.table.planner.delegation.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) |
| Modifier and Type | Method and Description |
|---|---|
protected OpFusionCodegenSpecGenerator |
BatchExecRuntimeFilter.translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecRuntimeFilter.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecGlobalRuntimeFilterBuilder.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
BatchExecLocalRuntimeFilterBuilder.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
| 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(org.apache.flink.table.planner.delegation.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> |
CommonExecCorrelate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
CommonExecExpand.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
CommonExecTableSourceScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
CommonExecPythonCalc.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
CommonExecUnion.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
CommonExecWindowTableFunction.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
CommonExecAsyncCalc.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
CommonExecPythonCorrelate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
CommonExecLegacyTableSourceScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
CommonExecValues.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
CommonExecCalc.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<T> |
CommonExecLegacySink.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
CommonExecMatch.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected abstract org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
CommonExecWindowTableFunction.translateWithUnalignedWindow(org.apache.flink.table.planner.delegation.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) |
| 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> |
StreamExecRank.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecLocalGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecOverAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecGroupTableAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecPythonGroupWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecTemporalJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecTemporalSort.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecMultipleInput.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecGroupWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecLimit.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecWindowDeduplicate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecLocalWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<Object> |
StreamExecSink.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecWindowJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecIntervalJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecExchange.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecSort.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecPythonGroupTableAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecDropUpdateBefore.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecWindowRank.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecGlobalWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecLookupJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecChangelogNormalize.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecSortLimit.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecPythonOverAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecDeduplicate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecGlobalGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecMiniBatchAssigner.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecDataStreamScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecIncrementalGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecPythonGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecWatermarkAssigner.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
StreamExecWindowTableFunction.translateWithUnalignedWindow(org.apache.flink.table.planner.delegation.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) |
| 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) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.