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

Class SlicingWindowAggOperatorBuilder

java.lang.Object

org.apache.flink.table.runtime.operators.aggregate.window.SlicingWindowAggOperatorBuilder

public class SlicingWindowAggOperatorBuilder
extends Object

The SlicingWindowAggOperatorBuilder is used to build a SlicingWindowOperator for window aggregate.

 SlicingWindowAggOperatorBuilder.builder()
   .inputType(inputType)
   .keyTypes(keyFieldTypes)
   .assigner(SliceAssigners.tumbling(rowtimeIndex, Duration.ofSeconds(5)))
   .aggregate(genAggsFunction), accTypes)
   .build();
 

Constructor Summary

Constructors

Constructor	Description
SlicingWindowAggOperatorBuilder()

Method Summary

Modifier and Type	Method	Description
SlicingWindowAggOperatorBuilder	aggregate(GeneratedNamespaceAggsHandleFunction<Long> generatedAggregateFunction, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> accSerializer)
SlicingWindowAggOperatorBuilder	assigner(SliceAssigner assigner)
SlicingWindowOperator<org.apache.flink.table.data.RowData,?>	build()
static SlicingWindowAggOperatorBuilder	builder()
SlicingWindowAggOperatorBuilder	countStarIndex(int indexOfCountStart)	Specify the index position of the COUNT(*) value in the accumulator buffer.
SlicingWindowAggOperatorBuilder	globalAggregate(GeneratedNamespaceAggsHandleFunction<Long> localGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<Long> globalGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<Long> stateGeneratedAggregateFunction, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> accSerializer)
SlicingWindowAggOperatorBuilder	inputSerializer(AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSerializer)
SlicingWindowAggOperatorBuilder	keySerializer(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySerializer)
SlicingWindowAggOperatorBuilder	shiftTimeZone(java.time.ZoneId shiftTimeZone)

Methods inherited from class java.lang.Object

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

Constructor Detail

SlicingWindowAggOperatorBuilder

public SlicingWindowAggOperatorBuilder()

Method Detail

builder

public static SlicingWindowAggOperatorBuilder builder()

inputSerializer

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

shiftTimeZone

public SlicingWindowAggOperatorBuilder shiftTimeZone(java.time.ZoneId shiftTimeZone)

keySerializer

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

assigner

public SlicingWindowAggOperatorBuilder assigner(SliceAssigner assigner)

aggregate

public SlicingWindowAggOperatorBuilder aggregate(GeneratedNamespaceAggsHandleFunction<Long> generatedAggregateFunction,
                                                 AbstractRowDataSerializer<org.apache.flink.table.data.RowData> accSerializer)

globalAggregate

public SlicingWindowAggOperatorBuilder globalAggregate(GeneratedNamespaceAggsHandleFunction<Long> localGeneratedAggregateFunction,
                                                       GeneratedNamespaceAggsHandleFunction<Long> globalGeneratedAggregateFunction,
                                                       GeneratedNamespaceAggsHandleFunction<Long> stateGeneratedAggregateFunction,
                                                       AbstractRowDataSerializer<org.apache.flink.table.data.RowData> accSerializer)

countStarIndex

public SlicingWindowAggOperatorBuilder countStarIndex(int indexOfCountStart)

Specify the index position of the COUNT(*) value in the accumulator buffer. This is only required for Hopping windows which uses this to determine whether the window is empty and then decide whether to register timer for the next window.

See Also:

SliceAssigners.HoppingSliceAssigner.nextTriggerWindow(long, Supplier)

build

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