Uses of Class
org.apache.flink.table.runtime.functions.aggregate.CollectAggFunction.CollectAccumulator
-
Packages that use CollectAggFunction.CollectAccumulator Package Description org.apache.flink.table.runtime.functions.aggregate -
-
Uses of CollectAggFunction.CollectAccumulator in org.apache.flink.table.runtime.functions.aggregate
Methods in org.apache.flink.table.runtime.functions.aggregate that return CollectAggFunction.CollectAccumulator Modifier and Type Method Description CollectAggFunction.CollectAccumulator<T>CollectAggFunction. createAccumulator()Methods in org.apache.flink.table.runtime.functions.aggregate with parameters of type CollectAggFunction.CollectAccumulator Modifier and Type Method Description voidCollectAggFunction. accumulate(CollectAggFunction.CollectAccumulator<T> accumulator, T value)org.apache.flink.table.data.MapDataCollectAggFunction. getValue(CollectAggFunction.CollectAccumulator<T> accumulator)voidCollectAggFunction. merge(CollectAggFunction.CollectAccumulator<T> accumulator, Iterable<CollectAggFunction.CollectAccumulator<T>> others)voidCollectAggFunction. resetAccumulator(CollectAggFunction.CollectAccumulator<T> accumulator)voidCollectAggFunction. retract(CollectAggFunction.CollectAccumulator<T> accumulator, T value)Method parameters in org.apache.flink.table.runtime.functions.aggregate with type arguments of type CollectAggFunction.CollectAccumulator Modifier and Type Method Description voidCollectAggFunction. merge(CollectAggFunction.CollectAccumulator<T> accumulator, Iterable<CollectAggFunction.CollectAccumulator<T>> others)
-