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

Interface Summary

Interface	Description
AggregatingState<IN,OUT>	State interface for aggregating state, based on an AggregateFunction.
AggregatingStateDeclaration<IN,ACC,OUT>	This represents a declaration of the aggregating state.
AppendingState<IN,OUT>	Base interface for partitioned state that supports adding elements and inspecting the current state.
BroadcastState<K,V>	A type of state that can be created to store the state of a BroadcastStream.
BroadcastStateDeclaration<K,V>	This represents a declaration of the broadcast state.
ListState<T>	State interface for partitioned list state in Operations.
ListStateDeclaration<T>	This represents a declaration of the list state.
MapState<UK,UV>	State interface for partitioned key-value state.
MapStateDeclaration<K,V>	This represents a declaration of the map state.
MergingState<IN,OUT>	Extension of AppendingState that allows merging of state.
ReadOnlyBroadcastState<K,V>	A read-only view of the BroadcastState.
ReducingState<T>	State interface for reducing state.
ReducingStateDeclaration<T>	This represents a declaration of the reducing state.
State	Interface that different types of partitioned state must implement.
StateDeclaration	StateDeclaration represents a declaration of the specific state used.
ValueState<T>	State interface for partitioned single-value state.
ValueStateDeclaration<T>	This represents a declaration of the value state.

Class Summary

Class	Description
StateDeclarations	This is a helper class for declaring various states.
StateDeclarations.AggregatingStateDeclarationBuilder<IN,OUT,ACC>	Builder for AggregatingStateDeclaration.
StateDeclarations.ListStateDeclarationBuilder<T>	Builder for ListStateDeclaration.
StateDeclarations.MapStateDeclarationBuilder<K,V>	Builder for MapStateDeclaration.
StateDeclarations.ReducingStateDeclarationBuilder<T>	Builder for ReducingStateDeclaration.
StateDeclarations.ValueStateDeclarationBuilder<T>	Builder for ValueStateDeclaration.

Enum Summary

Enum	Description
ListStateDeclaration.RedistributionStrategy	ListStateDeclaration.RedistributionStrategy is used to guide the assignment of states during rescaling.
StateDeclaration.RedistributionMode	StateDeclaration.RedistributionMode is used to indicate whether this state supports redistribution between partitions and how to redistribute this state during rescaling.

Exception Summary

Exception	Description
IllegalRedistributionModeException	A special IllegalStateException indicating a mismatch in StateDeclaration.