Class StreamExecWindowDeduplicate
- java.lang.Object
-
- org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase<RowData>
-
- org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecWindowDeduplicate
-
- All Implemented Interfaces:
ExecNode<RowData>
,ExecNodeTranslator<RowData>
,FusionCodegenExecNode
,SingleTransformationTranslator<RowData>
,StreamExecNode<RowData>
@ExecNodeMetadata(name="stream-exec-window-deduplicate", version=1, consumedOptions="table.local-time-zone", producedTransformations="window-deduplicate", minPlanVersion=v1_15, minStateVersion=v1_15) public class StreamExecWindowDeduplicate extends ExecNodeBase<RowData> implements StreamExecNode<RowData>, SingleTransformationTranslator<RowData>
StreamExecNode
for Window Deduplicate.
-
-
Field Summary
Fields Modifier and Type Field Description static String
FIELD_NAME_KEEP_LAST_ROW
static String
FIELD_NAME_ORDER_KEY
static String
FIELD_NAME_PARTITION_KEYS
static String
FIELD_NAME_WINDOWING
static String
WINDOW_DEDUPLICATE_TRANSFORMATION
-
Fields inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNode
FIELD_NAME_CONFIGURATION, FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE, FIELD_NAME_STATE, FIELD_NAME_TYPE
-
-
Constructor Summary
Constructors Constructor Description StreamExecWindowDeduplicate(int id, ExecNodeContext context, ReadableConfig persistedConfig, int[] partitionKeys, int orderKey, boolean keepLastRow, WindowingStrategy windowing, List<InputProperty> inputProperties, RowType outputType, String description)
StreamExecWindowDeduplicate(ReadableConfig tableConfig, int[] partitionKeys, int orderKey, boolean keepLastRow, WindowingStrategy windowing, InputProperty inputProperty, RowType outputType, String description)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Transformation<RowData>
translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
Internal method, translates this node into a Flink operator.-
Methods inherited from class org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase
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
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNode
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setCompiled, setInputEdges
-
Methods inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNodeTranslator
translateToPlan
-
Methods inherited from interface org.apache.flink.table.planner.plan.nodes.exec.FusionCodegenExecNode
supportFusionCodegen, translateToFusionCodegenSpec
-
-
-
-
Field Detail
-
WINDOW_DEDUPLICATE_TRANSFORMATION
public static final String WINDOW_DEDUPLICATE_TRANSFORMATION
- See Also:
- Constant Field Values
-
FIELD_NAME_PARTITION_KEYS
public static final String FIELD_NAME_PARTITION_KEYS
- See Also:
- Constant Field Values
-
FIELD_NAME_ORDER_KEY
public static final String FIELD_NAME_ORDER_KEY
- See Also:
- Constant Field Values
-
FIELD_NAME_KEEP_LAST_ROW
public static final String FIELD_NAME_KEEP_LAST_ROW
- See Also:
- Constant Field Values
-
FIELD_NAME_WINDOWING
public static final String FIELD_NAME_WINDOWING
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
StreamExecWindowDeduplicate
public StreamExecWindowDeduplicate(ReadableConfig tableConfig, int[] partitionKeys, int orderKey, boolean keepLastRow, WindowingStrategy windowing, InputProperty inputProperty, RowType outputType, String description)
-
StreamExecWindowDeduplicate
public StreamExecWindowDeduplicate(int id, ExecNodeContext context, ReadableConfig persistedConfig, int[] partitionKeys, int orderKey, boolean keepLastRow, WindowingStrategy windowing, List<InputProperty> inputProperties, RowType outputType, String description)
-
-
Method Detail
-
translateToPlanInternal
protected Transformation<RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
Description copied from class:ExecNodeBase
Internal method, translates this node into a Flink operator.- Specified by:
translateToPlanInternal
in classExecNodeBase<RowData>
- Parameters:
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 theplanner
. For more details checkExecNodeConfig
.
-
-