Modifier and Type | Method and Description |
---|---|
static ExecNodeConfig |
ExecNodeConfig.ofNodeConfig(ReadableConfig nodeConfig,
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. |
protected abstract 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 Transformation<RowData> |
BatchExecLegacyTableSourceScan.createConversionTransformationIfNeeded(StreamExecutionEnvironment streamExecEnv,
ExecNodeConfig config,
ClassLoader classLoader,
Transformation<?> sourceTransform,
org.apache.calcite.rex.RexNode rowtimeExpression) |
protected Transformation<RowData> |
BatchExecScriptTransform.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecLegacyTableSourceScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecPythonGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<Object> |
BatchExecDynamicFilteringDataCollector.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecSortWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<Object> |
BatchExecSink.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecExchange.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecWindowTableFunction.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecValues.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecMultipleInput.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecSort.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecSortLimit.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecSortAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecHashJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecSortMergeJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecBoundedStreamScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
Transformation<RowData> |
BatchExecLookupJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecOverAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecHashAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecRank.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecHashWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecPythonOverAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecTableSourceScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecNestedLoopJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecLimit.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
BatchExecPythonGroupWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
Modifier and Type | Method and Description |
---|---|
protected abstract Transformation<RowData> |
CommonExecLegacyTableSourceScan.createConversionTransformationIfNeeded(StreamExecutionEnvironment streamExecEnv,
ExecNodeConfig config,
ClassLoader classLoader,
Transformation<?> sourceTransform,
org.apache.calcite.rex.RexNode rowtimeExpression) |
protected Transformation<RowData> |
CommonExecLookupJoin.createJoinTransformation(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
boolean upsertMaterialize,
boolean lookupKeyContainsPrimaryKey) |
protected Transformation<Object> |
CommonExecSink.createSinkTransformation(StreamExecutionEnvironment streamExecEnv,
ExecNodeConfig config,
ClassLoader classLoader,
Transformation<RowData> inputTransform,
DynamicTableSink tableSink,
int rowtimeFieldIndex,
boolean upsertMaterialize,
int[] inputUpsertKey) |
protected Transformation<RowData> |
CommonExecMatch.translateOrder(Transformation<RowData> inputTransform,
RowType inputRowType,
ExecNodeConfig config) |
protected Transformation<T> |
CommonExecLegacySink.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
CommonExecMatch.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
CommonExecWindowTableFunction.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
CommonExecCalc.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
CommonExecLegacyTableSourceScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
CommonExecPythonCorrelate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
CommonExecValues.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
CommonExecCorrelate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
CommonExecExpand.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
CommonExecUnion.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
CommonExecTableSourceScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
CommonExecPythonCalc.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
Modifier and Type | Method and Description |
---|---|
protected Transformation<RowData> |
StreamExecLegacyTableSourceScan.createConversionTransformationIfNeeded(StreamExecutionEnvironment streamExecEnv,
ExecNodeConfig config,
ClassLoader classLoader,
Transformation<?> sourceTransform,
org.apache.calcite.rex.RexNode rowtimeExpression) |
Transformation<RowData> |
StreamExecMatch.translateOrder(Transformation<RowData> inputTransform,
RowType inputRowType,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecMiniBatchAssigner.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecMultipleInput.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecLocalWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecSort.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecTemporalJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecExchange.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecGroupTableAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecPythonGroupWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecChangelogNormalize.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecWindowDeduplicate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecIncrementalGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecOverAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecIntervalJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecPythonOverAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecWatermarkAssigner.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecDataStreamScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecTemporalSort.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecDropUpdateBefore.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecWindowJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecLocalGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecDeduplicate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecPythonGroupTableAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecGlobalWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecGroupWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecLimit.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
Transformation<RowData> |
StreamExecLookupJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecGlobalGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecWindowRank.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecRank.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecSortLimit.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<Object> |
StreamExecSink.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecPythonGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
protected Transformation<RowData> |
StreamExecJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config) |
Modifier and Type | Method and Description |
---|---|
static SortMergeJoinFunction |
SorMergeJoinOperatorUtil.getSortMergeJoinFunction(ClassLoader classLoader,
ExecNodeConfig config,
FlinkJoinType joinType,
RowType leftType,
RowType rightType,
int[] leftKeys,
int[] rightKeys,
RowType keyType,
boolean leftIsSmaller,
boolean[] filterNulls,
GeneratedJoinCondition condFunc,
double externalBufferMemRatio) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.