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

Class WindowRankOperatorBuilder

java.lang.Object

org.apache.flink.table.runtime.operators.rank.window.WindowRankOperatorBuilder

public class WindowRankOperatorBuilder
extends Object

The WindowRankOperatorBuilder is used to build a WindowAggOperator for window rank.

 SlicingWindowRankOperatorBuilder.builder()
   .inputSerializer(inputSerializer)
   .keySerializer(keySerializer)
   .sortKeySelector(sortKeySelector)
   .sortKeyComparator(genSortKeyComparator)
   .outputRankNumber(true)
   .rankStart(0)
   .rankEnd(100)
   .windowEndIndex(windowEndIndex)
   .withEventTime(true)
   .build();
 

Constructor Summary

Constructors

Constructor	Description
WindowRankOperatorBuilder()

Method Summary

Modifier and Type	Method	Description
WindowAggOperator<org.apache.flink.table.data.RowData,?>	build()
static WindowRankOperatorBuilder	builder()
WindowRankOperatorBuilder	inputSerializer(AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSerializer)
WindowRankOperatorBuilder	keySerializer(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySerializer)
WindowRankOperatorBuilder	outputRankNumber(boolean outputRankNumber)
WindowRankOperatorBuilder	rankEnd(long rankEnd)
WindowRankOperatorBuilder	rankStart(long rankStart)
WindowRankOperatorBuilder	shiftTimeZone(java.time.ZoneId shiftTimeZone)
WindowRankOperatorBuilder	sortKeyComparator(GeneratedRecordComparator genSortKeyComparator)
WindowRankOperatorBuilder	sortKeySelector(RowDataKeySelector sortKeySelector)
WindowRankOperatorBuilder	windowEndIndex(int windowEndIndex)
WindowRankOperatorBuilder	withEventTime(Boolean isEventTime)

Methods inherited from class java.lang.Object

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

Constructor Detail

WindowRankOperatorBuilder

public WindowRankOperatorBuilder()

Method Detail

builder

public static WindowRankOperatorBuilder builder()

inputSerializer

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

shiftTimeZone

public WindowRankOperatorBuilder shiftTimeZone(java.time.ZoneId shiftTimeZone)

keySerializer

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

sortKeySelector

public WindowRankOperatorBuilder sortKeySelector(RowDataKeySelector sortKeySelector)

sortKeyComparator

public WindowRankOperatorBuilder sortKeyComparator(GeneratedRecordComparator genSortKeyComparator)

outputRankNumber

public WindowRankOperatorBuilder outputRankNumber(boolean outputRankNumber)

rankStart

public WindowRankOperatorBuilder rankStart(long rankStart)

rankEnd

public WindowRankOperatorBuilder rankEnd(long rankEnd)

windowEndIndex

public WindowRankOperatorBuilder windowEndIndex(int windowEndIndex)

withEventTime

public WindowRankOperatorBuilder withEventTime(Boolean isEventTime)

build

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