public class StreamExecRank extends ExecNodeBase<RowData> implements StreamExecNode<RowData>, SingleTransformationTranslator<RowData>
ExecNode
for Rank.Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_GENERATE_UPDATE_BEFORE |
static String |
FIELD_NAME_OUTPUT_RANK_NUMBER |
static String |
FIELD_NAME_PARTITION_SPEC |
static String |
FIELD_NAME_RANK_RANG |
static String |
FIELD_NAME_RANK_STRATEGY |
static String |
FIELD_NAME_RANK_TYPE |
static String |
FIELD_NAME_SORT_SPEC |
static ConfigOption<Long> |
TABLE_EXEC_TOPN_CACHE_SIZE |
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and 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) |
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
@Experimental public static final ConfigOption<Long> TABLE_EXEC_TOPN_CACHE_SIZE
public static final String FIELD_NAME_RANK_TYPE
public static final String FIELD_NAME_PARTITION_SPEC
public static final String FIELD_NAME_SORT_SPEC
public static final String FIELD_NAME_RANK_RANG
public static final String FIELD_NAME_RANK_STRATEGY
public static final String FIELD_NAME_GENERATE_UPDATE_BEFORE
public static final String FIELD_NAME_OUTPUT_RANK_NUMBER
public StreamExecRank(RankType rankType, PartitionSpec partitionSpec, SortSpec sortSpec, RankRange rankRange, RankProcessStrategy rankStrategy, boolean outputRankNumber, boolean generateUpdateBefore, InputProperty inputProperty, RowType outputType, String description)
public StreamExecRank(RankType rankType, PartitionSpec partitionSpec, SortSpec sortSpec, RankRange rankRange, RankProcessStrategy rankStrategy, boolean outputRankNumber, 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 ExecNodeBase<RowData>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.