Uses of Interface
org.apache.flink.api.common.functions.ReduceFunction
-
Packages that use ReduceFunction Package Description org.apache.flink.api.common.functions org.apache.flink.api.common.operators.base org.apache.flink.api.common.state -
-
Uses of ReduceFunction in org.apache.flink.api.common.functions
Classes in org.apache.flink.api.common.functions that implement ReduceFunction Modifier and Type Class Description classRichReduceFunction<T>Rich variant of theReduceFunction. -
Uses of ReduceFunction in org.apache.flink.api.common.operators.base
Classes in org.apache.flink.api.common.operators.base with type parameters of type ReduceFunction Modifier and Type Class Description classReduceOperatorBase<T,FT extends ReduceFunction<T>>Base data flow operator for Reduce user-defined functions. -
Uses of ReduceFunction in org.apache.flink.api.common.state
Methods in org.apache.flink.api.common.state that return ReduceFunction Modifier and Type Method Description ReduceFunction<T>ReducingStateDescriptor. getReduceFunction()Returns the reduce function to be used for the reducing state.Constructors in org.apache.flink.api.common.state with parameters of type ReduceFunction Constructor Description ReducingStateDescriptor(String name, ReduceFunction<T> reduceFunction, Class<T> typeClass)Creates a newReducingStateDescriptorwith the given name, type, and default value.ReducingStateDescriptor(String name, ReduceFunction<T> reduceFunction, TypeInformation<T> typeInfo)Creates a newReducingStateDescriptorwith the given name and default value.ReducingStateDescriptor(String name, ReduceFunction<T> reduceFunction, TypeSerializer<T> typeSerializer)Creates a newValueStateDescriptorwith the given name and default value.
-