public class StreamExecDeduplicate extends ExecNodeBase<RowData> implements StreamExecNode<RowData>, SingleTransformationTranslator<RowData>
ExecNode
which deduplicate on keys and keeps only first row or last row. This node
is an optimization of StreamExecRank
for some special cases. Compared to StreamExecRank
, this node could use mini-batch and access less state.Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_GENERATE_UPDATE_BEFORE |
static String |
FIELD_NAME_IS_ROWTIME |
static String |
FIELD_NAME_KEEP_LAST_ROW |
static String |
FIELD_NAME_UNIQUE_KEYS |
static ConfigOption<Boolean> |
TABLE_EXEC_INSERT_AND_UPDATE_AFTER_SENSITIVE |
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
StreamExecDeduplicate(int[] uniqueKeys,
boolean isRowtime,
boolean keepLastRow,
boolean generateUpdateBefore,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecDeduplicate(int[] uniqueKeys,
boolean isRowtime,
boolean keepLastRow,
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
public static final String FIELD_NAME_UNIQUE_KEYS
public static final String FIELD_NAME_IS_ROWTIME
public static final String FIELD_NAME_KEEP_LAST_ROW
public static final String FIELD_NAME_GENERATE_UPDATE_BEFORE
@Experimental public static final ConfigOption<Boolean> TABLE_EXEC_INSERT_AND_UPDATE_AFTER_SENSITIVE
public StreamExecDeduplicate(int[] uniqueKeys, boolean isRowtime, boolean keepLastRow, boolean generateUpdateBefore, InputProperty inputProperty, RowType outputType, String description)
public StreamExecDeduplicate(int[] uniqueKeys, boolean isRowtime, boolean keepLastRow, 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.