Uses of Interface
org.apache.flink.api.common.functions.AggregateFunction
-
Packages that use AggregateFunction Package Description org.apache.flink.api.common.state -
-
Uses of AggregateFunction in org.apache.flink.api.common.state
Methods in org.apache.flink.api.common.state that return AggregateFunction Modifier and Type Method Description AggregateFunction<IN,ACC,OUT>AggregatingStateDeclaration. getAggregateFunction()Get the aggregate function of this state.Methods in org.apache.flink.api.common.state with parameters of type AggregateFunction Modifier and Type Method Description static <IN,ACC,OUT>
AggregatingStateDeclaration<IN,ACC,OUT>StateDeclarations. aggregatingState(String name, TypeDescriptor<ACC> aggTypeDescriptor, AggregateFunction<IN,ACC,OUT> aggregateFunction)Get theAggregatingStateDeclarationof aggregating state.static <IN,OUT,ACC>
StateDeclarations.AggregatingStateDeclarationBuilder<IN,OUT,ACC>StateDeclarations. aggregatingStateBuilder(String name, TypeDescriptor<ACC> aggTypeDescriptor, AggregateFunction<IN,ACC,OUT> aggregateFunction)Get the builder ofAggregatingStateDeclaration.Constructors in org.apache.flink.api.common.state with parameters of type AggregateFunction Constructor Description AggregatingStateDeclarationBuilder(String name, TypeDescriptor<ACC> stateTypeDescriptor, AggregateFunction<IN,ACC,OUT> aggregateFunction)
-