| 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(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.
|
| 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) |
| 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) |
| 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) |
| 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) |
| 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–2025 The Apache Software Foundation. All rights reserved.