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

Class DeduplicateFunctionHelper

java.lang.Object

org.apache.flink.table.runtime.operators.deduplicate.DeduplicateFunctionHelper

public class DeduplicateFunctionHelper
extends Object

Utility for deduplicate function.

Method Summary

Modifier and Type	Method and Description
static boolean	isDuplicate(RowData preRow, RowData currentRow, int rowtimeIndex, boolean keepLastRow) Returns current row is duplicate row or not compared to previous row.

Methods inherited from class java.lang.Object

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

Method Detail

isDuplicate

public static boolean isDuplicate(RowData preRow,
                                  RowData currentRow,
                                  int rowtimeIndex,
                                  boolean keepLastRow)

Returns current row is duplicate row or not compared to previous row.