StreamExecChangelogNormalize(Integer id,
ExecNodeContext context,
org.apache.flink.configuration.ReadableConfig persistedConfig,
int[] uniqueKeys,
boolean generateUpdateBefore,
List<StateMetadata> stateMetadataList,
List<InputProperty> inputProperties,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
StreamExecDeduplicate(int id,
ExecNodeContext context,
org.apache.flink.configuration.ReadableConfig persistedConfig,
int[] uniqueKeys,
boolean isRowtime,
boolean keepLastRow,
boolean generateUpdateBefore,
List<StateMetadata> stateMetadataList,
List<InputProperty> inputProperties,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
StreamExecGlobalGroupAggregate(int id,
ExecNodeContext context,
org.apache.flink.configuration.ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
org.apache.flink.table.types.logical.RowType localAggInputRowType,
boolean generateUpdateBefore,
boolean needRetraction,
Integer indexOfCountStar,
List<StateMetadata> stateMetadataList,
List<InputProperty> inputProperties,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
StreamExecGroupAggregate(int id,
ExecNodeContext context,
org.apache.flink.configuration.ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
List<StateMetadata> stateMetadataList,
List<InputProperty> inputProperties,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
StreamExecIncrementalGroupAggregate(int id,
ExecNodeContext context,
org.apache.flink.configuration.ReadableConfig persistedConfig,
int[] partialAggGrouping,
int[] finalAggGrouping,
org.apache.calcite.rel.core.AggregateCall[] partialOriginalAggCalls,
boolean[] partialAggCallNeedRetractions,
org.apache.flink.table.types.logical.RowType partialLocalAggInputType,
boolean partialAggNeedRetraction,
List<StateMetadata> stateMetadataList,
List<InputProperty> inputProperties,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
StreamExecJoin(int id,
ExecNodeContext context,
org.apache.flink.configuration.ReadableConfig persistedConfig,
JoinSpec joinSpec,
List<int[]> leftUpsertKeys,
List<int[]> rightUpsertKeys,
List<StateMetadata> stateMetadataList,
List<InputProperty> inputProperties,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
StreamExecLimit(int id,
ExecNodeContext context,
org.apache.flink.configuration.ReadableConfig persistedConfig,
org.apache.flink.table.runtime.operators.rank.ConstantRankRange rankRange,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
List<StateMetadata> stateMetadataList,
List<InputProperty> inputProperties,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
StreamExecLookupJoin(int id,
ExecNodeContext context,
org.apache.flink.configuration.ReadableConfig persistedConfig,
org.apache.flink.table.runtime.operators.join.FlinkJoinType joinType,
org.apache.calcite.rex.RexNode preFilterCondition,
org.apache.calcite.rex.RexNode remainingJoinCondition,
TemporalTableSourceSpec temporalTableSourceSpec,
Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable,
org.apache.calcite.rex.RexNode filterOnTemporalTable,
boolean lookupKeyContainsPrimaryKey,
boolean upsertMaterialize,
LookupJoinUtil.AsyncLookupOptions asyncLookupOptions,
LookupJoinUtil.RetryLookupOptions retryOptions,
org.apache.flink.table.connector.ChangelogMode inputChangelogMode,
List<StateMetadata> stateMetadataList,
List<InputProperty> inputProperties,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
StreamExecRank(int id,
ExecNodeContext context,
org.apache.flink.configuration.ReadableConfig persistedConfig,
org.apache.flink.table.runtime.operators.rank.RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
org.apache.flink.table.runtime.operators.rank.RankRange rankRange,
RankProcessStrategy rankStrategy,
boolean outputRankNumber,
boolean generateUpdateBefore,
List<StateMetadata> stateMetadataList,
List<InputProperty> inputProperties,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
StreamExecSink(int id,
ExecNodeContext context,
org.apache.flink.configuration.ReadableConfig persistedConfig,
DynamicTableSinkSpec tableSinkSpec,
org.apache.flink.table.connector.ChangelogMode inputChangelogMode,
boolean upsertMaterialize,
List<StateMetadata> stateMetadataList,
int[] inputUpsertKey,
List<InputProperty> inputProperties,
org.apache.flink.table.types.logical.LogicalType outputType,
String description) |
StreamExecSortLimit(int id,
ExecNodeContext context,
org.apache.flink.configuration.ReadableConfig persistedConfig,
SortSpec sortSpec,
org.apache.flink.table.runtime.operators.rank.ConstantRankRange rankRange,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
List<StateMetadata> stateMetadataList,
List<InputProperty> inputProperties,
org.apache.flink.table.types.logical.RowType outputType,
String description) |