public class StreamExecLimit extends StreamExecRank
ExecNode
for 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 |
---|
StreamExecLimit(ConstantRankRange rankRange,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLimit(long limitStart,
long limitEnd,
boolean generateUpdateBefore,
boolean needRetraction,
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 StreamExecLimit(long limitStart, long limitEnd, boolean generateUpdateBefore, boolean needRetraction, InputProperty inputProperty, RowType outputType, String description)
public StreamExecLimit(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–2022 The Apache Software Foundation. All rights reserved.