public class WindowRankOperatorBuilder extends Object
WindowRankOperatorBuilder
is used to build a SlicingWindowOperator
for window
rank.
SlicingWindowRankOperatorBuilder.builder() .inputSerializer(inputSerializer) .keySerializer(keySerializer) .sortKeySelector(sortKeySelector) .sortKeyComparator(genSortKeyComparator) .outputRankNumber(true) .rankStart(0) .rankEnd(100) .windowEndIndex(windowEndIndex) .build();
Constructor and Description |
---|
WindowRankOperatorBuilder() |
Modifier and Type | Method and Description |
---|---|
SlicingWindowOperator<RowData,?> |
build() |
static WindowRankOperatorBuilder |
builder() |
WindowRankOperatorBuilder |
inputSerializer(AbstractRowDataSerializer<RowData> inputSerializer) |
WindowRankOperatorBuilder |
keySerializer(PagedTypeSerializer<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) |
public static WindowRankOperatorBuilder builder()
public WindowRankOperatorBuilder inputSerializer(AbstractRowDataSerializer<RowData> inputSerializer)
public WindowRankOperatorBuilder shiftTimeZone(java.time.ZoneId shiftTimeZone)
public WindowRankOperatorBuilder keySerializer(PagedTypeSerializer<RowData> keySerializer)
public WindowRankOperatorBuilder sortKeySelector(RowDataKeySelector sortKeySelector)
public WindowRankOperatorBuilder sortKeyComparator(GeneratedRecordComparator genSortKeyComparator)
public WindowRankOperatorBuilder outputRankNumber(boolean outputRankNumber)
public WindowRankOperatorBuilder rankStart(long rankStart)
public WindowRankOperatorBuilder rankEnd(long rankEnd)
public WindowRankOperatorBuilder windowEndIndex(int windowEndIndex)
public SlicingWindowOperator<RowData,?> build()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.