SlicingWindowAggOperatorBuilder |
SlicingWindowAggOperatorBuilder.aggregate(GeneratedNamespaceAggsHandleFunction<Long> generatedAggregateFunction,
AbstractRowDataSerializer<RowData> accSerializer) |
SlicingWindowAggOperatorBuilder |
SlicingWindowAggOperatorBuilder.assigner(SliceAssigner assigner) |
static SlicingWindowAggOperatorBuilder |
SlicingWindowAggOperatorBuilder.builder() |
SlicingWindowAggOperatorBuilder |
SlicingWindowAggOperatorBuilder.countStarIndex(int indexOfCountStart)
Specify the index position of the COUNT(*) value in the accumulator buffer.
|
SlicingWindowAggOperatorBuilder |
SlicingWindowAggOperatorBuilder.globalAggregate(GeneratedNamespaceAggsHandleFunction<Long> localGeneratedAggregateFunction,
GeneratedNamespaceAggsHandleFunction<Long> globalGeneratedAggregateFunction,
GeneratedNamespaceAggsHandleFunction<Long> stateGeneratedAggregateFunction,
AbstractRowDataSerializer<RowData> accSerializer) |
SlicingWindowAggOperatorBuilder |
SlicingWindowAggOperatorBuilder.inputSerializer(AbstractRowDataSerializer<RowData> inputSerializer) |
SlicingWindowAggOperatorBuilder |
SlicingWindowAggOperatorBuilder.keySerializer(PagedTypeSerializer<RowData> keySerializer) |
SlicingWindowAggOperatorBuilder |
SlicingWindowAggOperatorBuilder.shiftTimeZone(java.time.ZoneId shiftTimeZone) |