Package org.apache.flink.table.runtime.operators.deduplicate.utils

Class RowTimeDeduplicateFunctionHelper

java.lang.Object

org.apache.flink.table.runtime.operators.deduplicate.utils.RowTimeDeduplicateFunctionHelper

public abstract class RowTimeDeduplicateFunctionHelper
extends Object

A helper to deduplicate data with row time in RowTimeDeduplicateFunction and AsyncStateRowTimeDeduplicateFunction.

Constructor Summary

Constructors

Constructor	Description
RowTimeDeduplicateFunctionHelper(boolean generateUpdateBefore, boolean generateInsert, int rowtimeIndex, boolean keepLastRow)

Method Summary

Modifier and Type	Method	Description
void	deduplicateOnRowTime(org.apache.flink.table.data.RowData currentRow, org.apache.flink.table.data.RowData prevRow, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)	Processes element to deduplicate on keys with row time semantic, sends current element if it is last or first row, retracts previous element if needed.
protected abstract void	updateState(org.apache.flink.table.data.RowData currentRow)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RowTimeDeduplicateFunctionHelper

public RowTimeDeduplicateFunctionHelper(boolean generateUpdateBefore,
                                        boolean generateInsert,
                                        int rowtimeIndex,
                                        boolean keepLastRow)

Method Detail

deduplicateOnRowTime

public void deduplicateOnRowTime(org.apache.flink.table.data.RowData currentRow,
                                 @Nullable
                                 org.apache.flink.table.data.RowData prevRow,
                                 org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
                          throws Exception

Processes element to deduplicate on keys with row time semantic, sends current element if it is last or first row, retracts previous element if needed.

Parameters:

currentRow - latest row received by deduplicate function

prevRow - previous row received by deduplicate function. `null` if current row is the first row

out - underlying collector

Throws:

Exception

updateState

protected abstract void updateState(org.apache.flink.table.data.RowData currentRow)
                             throws Exception

Throws:

Exception