Modifier and Type | Method and Description |
---|---|
protected ExecNodeContext |
ExecNodeBase.getContextFromAnnotation()
Retrieves the default context from the
ExecNodeMetadata annotation to be serialized
into the JSON plan. |
static <T extends ExecNode<?>> |
ExecNodeContext.newContext(Class<T> execNodeClass) |
ExecNodeContext |
ExecNodeContext.withId(int id)
Set the unique ID of the node, so that the
ExecNodeContext , together with the type
related name and version , stores all the necessary info to uniquely
reconstruct the ExecNode , and avoid storing the id independently as a field
in ExecNodeBase . |
Constructor and Description |
---|
ExecNodeBase(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
Constructor and Description |
---|
BatchExecOverAggregateBase(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
OverSpec overSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
Constructor and Description |
---|
CommonExecCalc(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<org.apache.calcite.rex.RexNode> projection,
org.apache.calcite.rex.RexNode condition,
Class<?> operatorBaseClass,
boolean retainHeader,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecCorrelate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
Class<?> operatorBaseClass,
boolean retainHeader,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecExchange(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecExpand(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<List<org.apache.calcite.rex.RexNode>> projects,
boolean retainHeader,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecLegacySink(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
TableSink<T> tableSink,
String[] upsertKeys,
boolean needRetraction,
boolean isStreaming,
InputProperty inputProperty,
LogicalType outputType,
String description) |
CommonExecLegacyTableSourceScan(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
TableSource<?> tableSource,
List<String> qualifiedName,
RowType outputType,
String description) |
CommonExecLookupJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode joinCondition,
TemporalTableSourceSpec temporalTableSourceSpec,
Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable,
org.apache.calcite.rex.RexNode filterOnTemporalTable,
LookupJoinUtil.AsyncLookupOptions asyncLookupOptions,
LookupJoinUtil.RetryLookupOptions retryOptions,
ChangelogMode inputChangelogMode,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecMatch(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
MatchSpec matchSpec,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
CommonExecPythonCalc(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<org.apache.calcite.rex.RexNode> projection,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecPythonCorrelate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecSink(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
boolean isBounded,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
CommonExecTableSourceScan(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
DynamicTableSourceSpec tableSourceSpec,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
CommonExecUnion(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecValues(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<List<RexLiteral>> tuples,
RowType outputType,
String description) |
CommonExecWindowTableFunction(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
TimeAttributeWindowingStrategy windowingStrategy,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
Constructor and Description |
---|
StreamExecAggregateBase(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
StreamExecCalc(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<org.apache.calcite.rex.RexNode> projection,
org.apache.calcite.rex.RexNode condition,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecChangelogNormalize(Integer id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] uniqueKeys,
boolean generateUpdateBefore,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecCorrelate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode invocation,
org.apache.calcite.rex.RexNode condition,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecDeduplicate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] uniqueKeys,
boolean isRowtime,
boolean keepLastRow,
boolean generateUpdateBefore,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecDropUpdateBefore(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecExchange(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecExpand(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<List<org.apache.calcite.rex.RexNode>> projects,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecGlobalGroupAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
RowType localAggInputRowType,
boolean generateUpdateBefore,
boolean needRetraction,
Integer indexOfCountStar,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecGlobalWindowAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
NamedWindowProperty[] namedWindowProperties,
List<InputProperty> inputProperties,
RowType localAggInputRowType,
RowType outputType,
String description) |
StreamExecGroupAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecGroupWindowAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
NamedWindowProperty[] namedWindowProperties,
boolean needRetraction,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecIncrementalGroupAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] partialAggGrouping,
int[] finalAggGrouping,
org.apache.calcite.rel.core.AggregateCall[] partialOriginalAggCalls,
boolean[] partialAggCallNeedRetractions,
RowType partialLocalAggInputType,
boolean partialAggNeedRetraction,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecIntervalJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
IntervalJoinSpec intervalJoinSpec,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
JoinSpec joinSpec,
List<int[]> leftUpsertKeys,
List<int[]> rightUpsertKeys,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLimit(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
ConstantRankRange rankRange,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLocalGroupAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean needRetraction,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLocalWindowAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLookupJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode joinCondition,
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,
ChangelogMode inputChangelogMode,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecMatch(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
MatchSpec matchSpec,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecMiniBatchAssigner(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
MiniBatchInterval miniBatchInterval,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecOverAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
OverSpec overSpec,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecPythonCalc(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<org.apache.calcite.rex.RexNode> projection,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecPythonCorrelate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode invocation,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecPythonGroupAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecPythonGroupWindowAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
NamedWindowProperty[] namedWindowProperties,
boolean generateUpdateBefore,
boolean needRetraction,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecPythonOverAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
OverSpec overSpec,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecRank(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
RankProcessStrategy rankStrategy,
boolean outputRankNumber,
boolean generateUpdateBefore,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecSink(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
List<InputProperty> inputProperties,
LogicalType outputType,
boolean upsertMaterialize,
int[] inputUpsertKey,
String description) |
StreamExecSortLimit(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
SortSpec sortSpec,
ConstantRankRange rankRange,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecTableSourceScan(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
DynamicTableSourceSpec tableSourceSpec,
RowType outputType,
String description) |
StreamExecTemporalJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
JoinSpec joinSpec,
boolean isTemporalTableFunctionJoin,
int leftTimeAttributeIndex,
int rightTimeAttributeIndex,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecTemporalSort(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
SortSpec sortSpec,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecUnion(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecValues(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<List<RexLiteral>> tuples,
RowType outputType,
String description) |
StreamExecWatermarkAssigner(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
org.apache.calcite.rex.RexNode watermarkExpr,
int rowtimeFieldIndex,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
NamedWindowProperty[] namedWindowProperties,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowAggregateBase(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
StreamExecWindowDeduplicate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] partitionKeys,
int orderKey,
boolean keepLastRow,
WindowingStrategy windowing,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
JoinSpec joinSpec,
WindowingStrategy leftWindowing,
WindowingStrategy rightWindowing,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowRank(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
boolean outputRankNumber,
WindowingStrategy windowing,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowTableFunction(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
TimeAttributeWindowingStrategy windowingStrategy,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.