Package org.apache.flink.state.forst.sync

Interface Summary

Interface	Description
ForStDBCachingPriorityQueueSet.OrderedByteArraySetCache	Cache that is organized as an ordered set for byte-arrays.

Class Summary

Class	Description
AbstractForStStateKeysIterator<K>	Base class for iterators over RocksDB column families.
AbstractForStSyncState<K,N,V>	Base class for State implementations that store state in a RocksDB database.
ForStDBCachingPriorityQueueSet<E extends org.apache.flink.runtime.state.heap.HeapPriorityQueueElement>	A priority queue with set semantics, implemented on top of RocksDB.
ForStDBPriorityQueueSetFactory	Encapsulates the logic and resources in connection with creating priority queue state structures, for RocksDB backend.
ForStIteratorWrapper	This class was originally a wrapper around RocksIterator to check the iterator status for all the methods mentioned to require this check in the wiki documentation: seek, next, seekToFirst, seekToLast, seekForPrev, and prev.
ForStPriorityQueueConfig	The configuration of ForSt priority queue state implementation.
ForStStateKeysAndNamespaceIterator<K,N>	Adapter class to bridge between ForStIteratorWrapper and Iterator to iterate over the keys and namespaces.
ForStStateKeysIterator<K>	Adapter class to bridge between ForStIteratorWrapper and Iterator to iterate over the keys.
ForStSyncKeyedStateBackend<K>	An AbstractKeyedStateBackend that stores its state in ForStDB and serializes state to streams provided by a CheckpointStreamFactory upon checkpointing.
ForStSyncKeyedStateBackendBuilder<K>	Builder class for ForStSyncKeyedStateBackend which handles all necessary initializations and clean ups.
TreeOrderedSetCache	Implementation of a lexicographically ordered set of byte-arrays, based on a TreeSet.