Package org.apache.flink.api.common.state

Interface AggregatingStateDeclaration<IN,ACC,OUT>

All Superinterfaces:

Serializable, StateDeclaration

@Experimental
public interface AggregatingStateDeclaration<IN,ACC,OUT>
extends StateDeclaration

This represents a declaration of the aggregating state.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.api.common.state.StateDeclaration

StateDeclaration.RedistributionMode

Method Summary

Modifier and Type	Method	Description
AggregateFunction<IN,ACC,OUT>	getAggregateFunction()	Get the aggregate function of this state.
TypeDescriptor<ACC>	getTypeDescriptor()	Get type descriptor of this state.

Methods inherited from interface org.apache.flink.api.common.state.StateDeclaration

getName, getRedistributionMode

Method Detail

getTypeDescriptor

TypeDescriptor<ACC> getTypeDescriptor()

Get type descriptor of this state.

getAggregateFunction

AggregateFunction<IN,ACC,OUT> getAggregateFunction()

Get the aggregate function of this state.