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

Interface ReducingStateDeclaration<T>

All Superinterfaces:

Serializable, StateDeclaration

@Experimental
public interface ReducingStateDeclaration<T>
extends StateDeclaration

This represents a declaration of the reducing 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
ReduceFunction<T>	getReduceFunction()	Get ReduceFunction associated with this reducing state.
TypeDescriptor<T>	getTypeDescriptor()	Get type descriptor of this reducing state.

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

getName, getRedistributionMode

Method Detail

getTypeDescriptor

TypeDescriptor<T> getTypeDescriptor()

Get type descriptor of this reducing state.

getReduceFunction

ReduceFunction<T> getReduceFunction()

Get ReduceFunction associated with this reducing state.