Uses of Class
org.apache.flink.table.runtime.operators.aggregate.window.SlicingWindowAggOperatorBuilder
-
Packages that use SlicingWindowAggOperatorBuilder Package Description org.apache.flink.table.runtime.operators.aggregate.window -
-
Uses of SlicingWindowAggOperatorBuilder in org.apache.flink.table.runtime.operators.aggregate.window
Methods in org.apache.flink.table.runtime.operators.aggregate.window that return SlicingWindowAggOperatorBuilder Modifier and Type Method Description SlicingWindowAggOperatorBuilderSlicingWindowAggOperatorBuilder. aggregate(GeneratedNamespaceAggsHandleFunction<Long> generatedAggregateFunction, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> accSerializer)SlicingWindowAggOperatorBuilderSlicingWindowAggOperatorBuilder. assigner(SliceAssigner assigner)static SlicingWindowAggOperatorBuilderSlicingWindowAggOperatorBuilder. builder()SlicingWindowAggOperatorBuilderSlicingWindowAggOperatorBuilder. countStarIndex(int indexOfCountStart)Specify the index position of the COUNT(*) value in the accumulator buffer.SlicingWindowAggOperatorBuilderSlicingWindowAggOperatorBuilder. globalAggregate(GeneratedNamespaceAggsHandleFunction<Long> localGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<Long> globalGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<Long> stateGeneratedAggregateFunction, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> accSerializer)SlicingWindowAggOperatorBuilderSlicingWindowAggOperatorBuilder. inputSerializer(AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSerializer)SlicingWindowAggOperatorBuilderSlicingWindowAggOperatorBuilder. keySerializer(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySerializer)SlicingWindowAggOperatorBuilderSlicingWindowAggOperatorBuilder. shiftTimeZone(java.time.ZoneId shiftTimeZone)
-