public class StreamExecSortLimit extends StreamExecRank
StreamExecNode
for Sort with limit.FIELD_NAME_GENERATE_UPDATE_BEFORE, FIELD_NAME_OUTPUT_RANK_NUMBER, FIELD_NAME_PARTITION_SPEC, FIELD_NAME_RANK_RANG, FIELD_NAME_RANK_STRATEGY, FIELD_NAME_RANK_TYPE, FIELD_NAME_SORT_SPEC, TABLE_EXEC_TOPN_CACHE_SIZE
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and 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 | Method and Description |
---|---|
protected Transformation<RowData> |
translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
Internal method, translates this node into a Flink operator.
|
accept, getDescription, getId, getInputEdges, getInputProperties, getNewNodeId, getOutputType, inputsContainSingleton, replaceInputEdge, resetIdCounter, setInputEdges, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setInputEdges
translateToPlan
public StreamExecSortLimit(SortSpec sortSpec, long limitStart, long limitEnd, RankProcessStrategy rankStrategy, boolean generateUpdateBefore, InputProperty inputProperty, RowType outputType, String description)
public StreamExecSortLimit(SortSpec sortSpec, ConstantRankRange rankRange, RankProcessStrategy rankStrategy, boolean generateUpdateBefore, int id, List<InputProperty> inputProperties, RowType outputType, String description)
protected Transformation<RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
ExecNodeBase
translateToPlanInternal
in class StreamExecRank
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.