@ExecNodeMetadata(name="stream-exec-limit", version=1, consumedOptions="table.exec.rank.topn-cache-size", producedTransformations="rank", minPlanVersion=v1_15, minStateVersion=v1_15) 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, RANK_TRANSFORMATION, STATE_NAME
FIELD_NAME_CONFIGURATION, FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE, FIELD_NAME_STATE, FIELD_NAME_TYPE
Constructor and Description |
---|
StreamExecLimit(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
ConstantRankRange rankRange,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
List<StateMetadata> stateMetadataList,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLimit(ReadableConfig tableConfig,
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,
ExecNodeConfig config)
Internal method, translates this node into a Flink operator.
|
accept, createFormattedTransformationDescription, createFormattedTransformationName, createTransformationDescription, createTransformationMeta, createTransformationMeta, createTransformationName, createTransformationUid, getContextFromAnnotation, getDescription, getId, getInputEdges, getInputProperties, getOutputType, getPersistedConfig, getSimplifiedName, getTransformation, inputsContainSingleton, replaceInputEdge, setCompiled, setInputEdges, supportFusionCodegen, translateToFusionCodegenSpec, translateToFusionCodegenSpecInternal, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setCompiled, setInputEdges
translateToPlan
supportFusionCodegen, translateToFusionCodegenSpec
public StreamExecLimit(ReadableConfig tableConfig, long limitStart, long limitEnd, boolean generateUpdateBefore, boolean needRetraction, InputProperty inputProperty, RowType outputType, String description)
public StreamExecLimit(int id, ExecNodeContext context, ReadableConfig persistedConfig, ConstantRankRange rankRange, RankProcessStrategy rankStrategy, boolean generateUpdateBefore, @Nullable List<StateMetadata> stateMetadataList, List<InputProperty> inputProperties, RowType outputType, String description)
protected Transformation<RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
ExecNodeBase
translateToPlanInternal
in class StreamExecRank
planner
- The planner.config
- per-ExecNode
configuration that contains the merged configuration from
various layers which all the nodes implementing this method should use, instead of
retrieving configuration from the planner
. For more details check ExecNodeConfig
.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.