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

Class RowTimeWindowDeduplicateOperatorBuilder

java.lang.Object

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

public class RowTimeWindowDeduplicateOperatorBuilder
extends Object

The RowTimeWindowDeduplicateOperatorBuilder is used to build a SlicingWindowOperator for rowtime window deduplicate.

 RowTimeWindowDeduplicateOperatorBuilder.builder()
   .inputSerializer(inputSerializer)
   .keySerializer(keySerializer)
   .keepLastRow(true)
   .rowtimeIndex(0)
   .windowEndIndex(windowEndIndex)
   .build();
 

Constructor Summary

Constructors

Constructor	Description
RowTimeWindowDeduplicateOperatorBuilder()

Method Summary

Modifier and Type	Method	Description
SlicingWindowOperator<org.apache.flink.table.data.RowData,?>	build()
static RowTimeWindowDeduplicateOperatorBuilder	builder()
RowTimeWindowDeduplicateOperatorBuilder	inputSerializer(AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSerializer)
RowTimeWindowDeduplicateOperatorBuilder	keepLastRow(boolean keepLastRow)
RowTimeWindowDeduplicateOperatorBuilder	keySerializer(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySerializer)
RowTimeWindowDeduplicateOperatorBuilder	rowtimeIndex(int rowtimeIndex)
RowTimeWindowDeduplicateOperatorBuilder	shiftTimeZone(java.time.ZoneId shiftTimeZone)
RowTimeWindowDeduplicateOperatorBuilder	windowEndIndex(int windowEndIndex)

Methods inherited from class java.lang.Object

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

Constructor Detail

RowTimeWindowDeduplicateOperatorBuilder

public RowTimeWindowDeduplicateOperatorBuilder()

Method Detail

builder

public static RowTimeWindowDeduplicateOperatorBuilder builder()

inputSerializer

public RowTimeWindowDeduplicateOperatorBuilder inputSerializer(AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSerializer)

shiftTimeZone

public RowTimeWindowDeduplicateOperatorBuilder shiftTimeZone(java.time.ZoneId shiftTimeZone)

keySerializer

public RowTimeWindowDeduplicateOperatorBuilder keySerializer(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySerializer)

keepLastRow

public RowTimeWindowDeduplicateOperatorBuilder keepLastRow(boolean keepLastRow)

rowtimeIndex

public RowTimeWindowDeduplicateOperatorBuilder rowtimeIndex(int rowtimeIndex)

windowEndIndex

public RowTimeWindowDeduplicateOperatorBuilder windowEndIndex(int windowEndIndex)

build

public SlicingWindowOperator<org.apache.flink.table.data.RowData,?> build()