Package | Description |
---|---|
org.apache.flink.table.planner.plan.nodes.exec.stream | |
org.apache.flink.table.planner.plan.utils |
Constructor and Description |
---|
StreamExecLimit(ConstantRankRange rankRange,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
int id,
List<InputProperty> inputProperties,
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) |
StreamExecRank(RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
RankProcessStrategy rankStrategy,
boolean outputRankNumber,
boolean generateUpdateBefore,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecSortLimit(SortSpec sortSpec,
ConstantRankRange rankRange,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecSortLimit(SortSpec sortSpec,
long limitStart,
long limitEnd,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
InputProperty inputProperty,
RowType outputType,
String description) |
Modifier and Type | Class and Description |
---|---|
static class |
RankProcessStrategy.AppendFastStrategy
A strategy which only works when input only contains insertion changes.
|
static class |
RankProcessStrategy.RetractStrategy
A strategy which works when input contains update or deletion changes.
|
static class |
RankProcessStrategy.UndefinedStrategy
A placeholder strategy which will be inferred after
FlinkChangelogModeInferenceProgram . |
static class |
RankProcessStrategy.UpdateFastStrategy
A strategy which only works when input shouldn't contains deletion changes and input should
have the given
RankProcessStrategy.UpdateFastStrategy.primaryKeys and should be monotonic on the order by field. |
Modifier and Type | Method and Description |
---|---|
static List<RankProcessStrategy> |
RankProcessStrategy.analyzeRankProcessStrategies(org.apache.flink.table.planner.plan.nodes.physical.stream.StreamPhysicalRel rank,
org.apache.calcite.util.ImmutableBitSet partitionKey,
org.apache.calcite.rel.RelCollation orderKey)
Gets
RankProcessStrategy based on input, partitionKey and orderKey. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.