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