public class SlicingWindowAggOperatorBuilder extends Object
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 and Description |
---|
SlicingWindowAggOperatorBuilder() |
public static SlicingWindowAggOperatorBuilder builder()
public SlicingWindowAggOperatorBuilder inputSerializer(AbstractRowDataSerializer<RowData> inputSerializer)
public SlicingWindowAggOperatorBuilder shiftTimeZone(ZoneId shiftTimeZone)
public SlicingWindowAggOperatorBuilder keySerializer(PagedTypeSerializer<RowData> keySerializer)
public SlicingWindowAggOperatorBuilder assigner(SliceAssigner assigner)
public SlicingWindowAggOperatorBuilder aggregate(GeneratedNamespaceAggsHandleFunction<Long> generatedAggregateFunction, AbstractRowDataSerializer<RowData> accSerializer)
public SlicingWindowAggOperatorBuilder globalAggregate(GeneratedNamespaceAggsHandleFunction<Long> localGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<Long> globalGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<Long> stateGeneratedAggregateFunction, AbstractRowDataSerializer<RowData> accSerializer)
public SlicingWindowAggOperatorBuilder countStarIndex(int indexOfCountStart)
public SlicingWindowOperator<RowData,?> build()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.