Package org.apache.flink.contrib.streaming.state

Interface Summary

Interface	Description
OptionsFactory	A factory for DBOptions to be passed to the RocksDBStateBackend.

Class Summary

Class	Description
AbstractRocksDBState<K,N,S extends org.apache.flink.api.common.state.State,SD extends org.apache.flink.api.common.state.StateDescriptor<S,V>,V>	Base class for State implementations that store state in a RocksDB database.
RocksDBAggregatingState<K,N,T,ACC,R>	An AggregatingState implementation that stores state in RocksDB.
RocksDBFoldingState<K,N,T,ACC>	Deprecated will be removed in a future version
RocksDBKeyedStateBackend<K>	A AbstractKeyedStateBackend that stores its state in RocksDB and will serialize state to streams provided by a CheckpointStreamFactory upon checkpointing.
RocksDBListState<K,N,V>	ListState implementation that stores state in RocksDB.
RocksDBMapState<K,N,UK,UV>	MapState implementation that stores state in RocksDB.
RocksDBReducingState<K,N,V>	ReducingState implementation that stores state in RocksDB.
RocksDBStateBackend	A State Backend that stores its state in RocksDB.
RocksDBStateBackendFactory	A factory that creates an RocksDBStateBackend from a configuration.
RocksDBValueState<K,N,V>	ValueState implementation that stores state in RocksDB.

Enum Summary

Enum	Description
PredefinedOptions	The PredefinedOptions are configuration settings for the RocksDBStateBackend.