Uses of Class
org.apache.flink.table.runtime.generated.GeneratedNamespaceAggsHandleFunction
-
-
Uses of GeneratedNamespaceAggsHandleFunction in org.apache.flink.table.runtime.operators.aggregate.window
Methods in org.apache.flink.table.runtime.operators.aggregate.window with parameters of type GeneratedNamespaceAggsHandleFunction Modifier and Type Method Description SlicingWindowAggOperatorBuilderSlicingWindowAggOperatorBuilder. aggregate(GeneratedNamespaceAggsHandleFunction<Long> generatedAggregateFunction, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> accSerializer)SlicingWindowAggOperatorBuilderSlicingWindowAggOperatorBuilder. globalAggregate(GeneratedNamespaceAggsHandleFunction<Long> localGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<Long> globalGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<Long> stateGeneratedAggregateFunction, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> accSerializer) -
Uses of GeneratedNamespaceAggsHandleFunction in org.apache.flink.table.runtime.operators.aggregate.window.combines
Constructors in org.apache.flink.table.runtime.operators.aggregate.window.combines with parameters of type GeneratedNamespaceAggsHandleFunction Constructor Description Factory(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler)Factory(GeneratedNamespaceAggsHandleFunction<Long> genLocalAggsHandler, GeneratedNamespaceAggsHandleFunction<Long> genGlobalAggsHandler)Factory(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler) -
Uses of GeneratedNamespaceAggsHandleFunction in org.apache.flink.table.runtime.operators.aggregate.window.processors
Fields in org.apache.flink.table.runtime.operators.aggregate.window.processors declared as GeneratedNamespaceAggsHandleFunction Modifier and Type Field Description protected GeneratedNamespaceAggsHandleFunction<Long>AbstractWindowAggProcessor. genAggsHandlerConstructors in org.apache.flink.table.runtime.operators.aggregate.window.processors with parameters of type GeneratedNamespaceAggsHandleFunction Constructor Description AbstractWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory bufferFactory, SliceAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, java.time.ZoneId shiftTimeZone)SliceSharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory bufferFactory, SliceSharedAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, int indexOfCountStar, java.time.ZoneId shiftTimeZone)SliceUnsharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory windowBufferFactory, SliceUnsharedAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, java.time.ZoneId shiftTimeZone) -
Uses of GeneratedNamespaceAggsHandleFunction in org.apache.flink.table.runtime.operators.window
Methods in org.apache.flink.table.runtime.operators.window with parameters of type GeneratedNamespaceAggsHandleFunction Modifier and Type Method Description WindowOperatorBuilder.AggregateWindowOperatorBuilderWindowOperatorBuilder. aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction, GeneratedRecordEqualiser generatedEqualiser, org.apache.flink.table.types.logical.LogicalType[] accumulatorTypes, org.apache.flink.table.types.logical.LogicalType[] aggResultTypes, org.apache.flink.table.types.logical.LogicalType[] windowPropertyTypes)Constructors in org.apache.flink.table.runtime.operators.window with parameters of type GeneratedNamespaceAggsHandleFunction Constructor Description AggregateWindowOperatorBuilder(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction, GeneratedRecordEqualiser generatedEqualiser, WindowOperatorBuilder windowOperatorBuilder)
-