public class WindowAggOperatorBuilder extends Object
WindowAggOperatorBuilder
is used to build a WindowAggOperator
with SlicingWindowProcessor
or a UnslicingWindowProcessor
.
WindowAggOperatorBuilder.builder() .inputType(inputType) .keyTypes(keyFieldTypes) .assigner(SliceAssigners.tumbling(rowtimeIndex, Duration.ofSeconds(5))) .aggregate(genAggsFunction), accTypes) .build();
or
WindowAggOperatorBuilder.builder() .inputType(inputType) .keyTypes(keyFieldTypes) .assigner(UnsliceAssigners.session(rowtimeIndex, Duration.ofSeconds(5))) .aggregate(genAggsFunction), accTypes) .build();
Constructor and Description |
---|
WindowAggOperatorBuilder() |
public static WindowAggOperatorBuilder builder()
public WindowAggOperatorBuilder inputSerializer(AbstractRowDataSerializer<RowData> inputSerializer)
public WindowAggOperatorBuilder shiftTimeZone(java.time.ZoneId shiftTimeZone)
public WindowAggOperatorBuilder keySerializer(PagedTypeSerializer<RowData> keySerializer)
public WindowAggOperatorBuilder assigner(WindowAssigner assigner)
public WindowAggOperatorBuilder aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction, AbstractRowDataSerializer<RowData> accSerializer)
public WindowAggOperatorBuilder globalAggregate(GeneratedNamespaceAggsHandleFunction<?> localGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<?> globalGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<?> stateGeneratedAggregateFunction, AbstractRowDataSerializer<RowData> accSerializer)
public WindowAggOperatorBuilder countStarIndex(int indexOfCountStart)
public WindowAggOperator<RowData,?> build()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.