Modifier and Type | Field and Description |
---|---|
static InputProperty |
InputProperty.DEFAULT |
Modifier and Type | Method and Description |
---|---|
InputProperty |
InputProperty.Builder.build() |
Modifier and Type | Method and Description |
---|---|
List<InputProperty> |
ExecNode.getInputProperties()
Returns a list of this node's input properties.
|
List<InputProperty> |
ExecNodeBase.getInputProperties() |
Constructor and Description |
---|
ExecNodeBase(int id,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
ExecNodeBase(List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
Constructor and Description |
---|
BatchExecCalc(List<org.apache.calcite.rex.RexNode> projection,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecCorrelate(FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecExchange(InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecExpand(List<List<org.apache.calcite.rex.RexNode>> projects,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecHashAggregate(int[] grouping,
int[] auxGrouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
RowType aggInputRowType,
boolean isMerge,
boolean isFinal,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecHashJoin(JoinSpec joinSpec,
int estimatedLeftAvgRowSize,
int estimatedRightAvgRowSize,
long estimatedLeftRowCount,
long estimatedRightRowCount,
boolean leftIsBuild,
boolean tryDistinctBuildRow,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
BatchExecHashWindowAggregate(int[] grouping,
int[] auxGrouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
int inputTimeFieldIndex,
boolean inputTimeIsDate,
PlannerNamedWindowProperty[] namedWindowProperties,
RowType aggInputRowType,
boolean enableAssignPane,
boolean isMerge,
boolean isFinal,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecLegacySink(TableSink<T> tableSink,
String[] upsertKeys,
InputProperty inputProperty,
LogicalType outputType,
String description) |
BatchExecLimit(long limitStart,
long limitEnd,
boolean isGlobal,
InputProperty inputProperty,
LogicalType outputType,
String description) |
BatchExecLookupJoin(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,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecNestedLoopJoin(FlinkJoinType joinType,
org.apache.calcite.rex.RexNode condition,
boolean leftIsBuild,
boolean singleRowJoin,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
BatchExecOverAggregate(OverSpec overSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecOverAggregateBase(OverSpec overSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecPythonCalc(org.apache.calcite.rex.RexProgram calcProgram,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecPythonCorrelate(FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecPythonGroupAggregate(int[] grouping,
int[] auxGrouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecPythonGroupWindowAggregate(int[] grouping,
int[] auxGrouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
int inputTimeFieldIndex,
PlannerNamedWindowProperty[] namedWindowProperties,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecPythonOverAggregate(OverSpec overSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecRank(int[] partitionFields,
int[] sortFields,
long rankStart,
long rankEnd,
boolean outputRankNumber,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecSink(DynamicTableSinkSpec tableSinkSpec,
InputProperty inputProperty,
LogicalType outputType,
String description) |
BatchExecSort(SortSpec sortSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecSortAggregate(int[] grouping,
int[] auxGrouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
RowType aggInputRowType,
boolean isMerge,
boolean isFinal,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecSortLimit(SortSpec sortSpec,
long limitStart,
long limitEnd,
boolean isGlobal,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecSortMergeJoin(FlinkJoinType joinType,
int[] leftKeys,
int[] rightKeys,
boolean[] filterNulls,
org.apache.calcite.rex.RexNode nonEquiCondition,
boolean leftIsSmaller,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
BatchExecSortWindowAggregate(int[] grouping,
int[] auxGrouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
int inputTimeFieldIndex,
boolean inputTimeIsDate,
PlannerNamedWindowProperty[] namedWindowProperties,
RowType aggInputRowType,
boolean enableAssignPane,
boolean isMerge,
boolean isFinal,
InputProperty inputProperty,
RowType outputType,
String description) |
Constructor and Description |
---|
BatchExecMultipleInput(List<InputProperty> inputProperties,
ExecNode<?> rootNode,
String description) |
BatchExecUnion(List<InputProperty> inputProperties,
RowType outputType,
String description) |
Constructor and Description |
---|
CommonExecLegacySink(TableSink<T> tableSink,
String[] upsertKeys,
boolean needRetraction,
boolean isStreaming,
InputProperty inputProperty,
LogicalType outputType,
String description) |
CommonExecPythonCalc(org.apache.calcite.rex.RexProgram calcProgram,
InputProperty inputProperty,
RowType outputType,
String description) |
CommonExecPythonCorrelate(FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
Constructor and Description |
---|
CommonExecCalc(List<org.apache.calcite.rex.RexNode> projection,
org.apache.calcite.rex.RexNode condition,
Class<?> operatorBaseClass,
boolean retainHeader,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecCorrelate(FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
Class<?> operatorBaseClass,
boolean retainHeader,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecExchange(int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecExpand(List<List<org.apache.calcite.rex.RexNode>> projects,
boolean retainHeader,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecLookupJoin(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,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecSink(DynamicTableSinkSpec tableSinkSpec,
ChangelogMode changelogMode,
boolean isBounded,
int id,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
CommonExecUnion(int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
Constructor and Description |
---|
StreamExecCalc(List<org.apache.calcite.rex.RexNode> projection,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecChangelogNormalize(int[] uniqueKeys,
boolean generateUpdateBefore,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecCorrelate(FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecDeduplicate(int[] uniqueKeys,
boolean isRowtime,
boolean keepLastRow,
boolean generateUpdateBefore,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecDropUpdateBefore(InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecExchange(InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecExpand(List<List<org.apache.calcite.rex.RexNode>> projects,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecGlobalGroupAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
RowType localAggInputRowType,
boolean generateUpdateBefore,
boolean needRetraction,
Integer indexOfCountStar,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecGlobalWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
PlannerNamedWindowProperty[] namedWindowProperties,
InputProperty inputProperty,
RowType localAggInputRowType,
RowType outputType,
String description) |
StreamExecGroupAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecGroupTableAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecGroupWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
PlannerNamedWindowProperty[] namedWindowProperties,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecIncrementalGroupAggregate(int[] partialAggGrouping,
int[] finalAggGrouping,
org.apache.calcite.rel.core.AggregateCall[] partialOriginalAggCalls,
boolean[] partialAggCallNeedRetractions,
RowType partialLocalAggInputType,
boolean partialAggNeedRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecIntervalJoin(IntervalJoinSpec intervalJoinSpec,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
StreamExecJoin(JoinSpec joinSpec,
List<int[]> leftUniqueKeys,
List<int[]> rightUniqueKeys,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
StreamExecLegacySink(TableSink<T> tableSink,
String[] upsertKeys,
boolean needRetraction,
InputProperty inputProperty,
LogicalType outputType,
String description) |
StreamExecLimit(long limitStart,
long limitEnd,
boolean generateUpdateBefore,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecLocalGroupAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecLocalWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecLookupJoin(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,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecMatch(MatchSpec matchSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecMiniBatchAssigner(MiniBatchInterval miniBatchInterval,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecOverAggregate(OverSpec overSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonCalc(org.apache.calcite.rex.RexProgram calcProgram,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonCorrelate(FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonGroupAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonGroupTableAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonGroupWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
PlannerNamedWindowProperty[] namedWindowProperties,
org.apache.flink.table.planner.plan.utils.WindowEmitStrategy emitStrategy,
boolean generateUpdateBefore,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonOverAggregate(OverSpec overSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecRank(RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
RankProcessStrategy rankStrategy,
boolean outputRankNumber,
boolean generateUpdateBefore,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecSink(DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
InputProperty inputProperty,
LogicalType outputType,
boolean upsertMaterialize,
String description) |
StreamExecSort(SortSpec sortSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecSortLimit(SortSpec sortSpec,
long limitStart,
long limitEnd,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecTemporalJoin(JoinSpec joinSpec,
boolean isTemporalTableFunctionJoin,
int leftTimeAttributeIndex,
int rightTimeAttributeIndex,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
StreamExecTemporalSort(SortSpec sortSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecWatermarkAssigner(org.apache.calcite.rex.RexNode watermarkExpr,
int rowtimeFieldIndex,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
PlannerNamedWindowProperty[] namedWindowProperties,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecWindowRank(RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
boolean outputRankNumber,
WindowingStrategy windowing,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecWindowTableFunction(WindowingStrategy windowingStrategy,
InputProperty inputEdge,
RowType outputType,
String description) |
Constructor and Description |
---|
StreamExecAggregateBase(int id,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
StreamExecCalc(List<org.apache.calcite.rex.RexNode> projection,
org.apache.calcite.rex.RexNode condition,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecChangelogNormalize(int[] uniqueKeys,
boolean generateUpdateBefore,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecCorrelate(FlinkJoinType joinType,
org.apache.calcite.rex.RexNode invocation,
org.apache.calcite.rex.RexNode condition,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecDeduplicate(int[] uniqueKeys,
boolean isRowtime,
boolean keepLastRow,
boolean generateUpdateBefore,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecDropUpdateBefore(int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecExchange(int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecExpand(List<List<org.apache.calcite.rex.RexNode>> projects,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecGlobalGroupAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
RowType localAggInputRowType,
boolean generateUpdateBefore,
boolean needRetraction,
Integer indexOfCountStar,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecGlobalWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
PlannerNamedWindowProperty[] namedWindowProperties,
int id,
List<InputProperty> inputProperties,
RowType localAggInputRowType,
RowType outputType,
String description) |
StreamExecGroupAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecGroupWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
PlannerNamedWindowProperty[] namedWindowProperties,
boolean needRetraction,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecIncrementalGroupAggregate(int[] partialAggGrouping,
int[] finalAggGrouping,
org.apache.calcite.rel.core.AggregateCall[] partialOriginalAggCalls,
boolean[] partialAggCallNeedRetractions,
RowType partialLocalAggInputType,
boolean partialAggNeedRetraction,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecIntervalJoin(IntervalJoinSpec intervalJoinSpec,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecJoin(JoinSpec joinSpec,
List<int[]> leftUniqueKeys,
List<int[]> rightUniqueKeys,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLimit(ConstantRankRange rankRange,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLocalGroupAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean needRetraction,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLocalWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLookupJoin(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,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecMatch(MatchSpec matchSpec,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecMiniBatchAssigner(MiniBatchInterval miniBatchInterval,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecMultipleInput(List<InputProperty> inputProperties,
ExecNode<?> rootNode,
String description) |
StreamExecOverAggregate(OverSpec overSpec,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecRank(RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
RankProcessStrategy rankStrategy,
boolean outputRankNumber,
boolean generateUpdateBefore,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecSink(DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
int id,
List<InputProperty> inputProperties,
LogicalType outputType,
boolean upsertMaterialize,
String description) |
StreamExecSortLimit(SortSpec sortSpec,
ConstantRankRange rankRange,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecTemporalJoin(JoinSpec joinSpec,
boolean isTemporalTableFunctionJoin,
int leftTimeAttributeIndex,
int rightTimeAttributeIndex,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecTemporalSort(SortSpec sortSpec,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecUnion(int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecUnion(List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWatermarkAssigner(org.apache.calcite.rex.RexNode watermarkExpr,
int rowtimeFieldIndex,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
PlannerNamedWindowProperty[] namedWindowProperties,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowAggregateBase(int id,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
StreamExecWindowRank(RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
boolean outputRankNumber,
WindowingStrategy windowing,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
static String |
ExecNodeUtil.getMultipleInputDescription(ExecNode<?> rootNode,
List<ExecNode<?>> inputNodes,
List<InputProperty> inputProperties)
Return description for multiple input node.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.