Package org.apache.flink.state.rocksdb

Interface Summary

Interface	Description
ConfigurableRocksDBOptionsFactory	An interface for options factory that pick up additional parameters from a configuration.
RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache	Cache that is organized as an ordered set for byte-arrays.
RocksDBMemoryControllerUtils.RocksDBMemoryFactory	Factory for Write Buffer Manager and Bock Cache.
RocksDBOptionsFactory	A factory for DBOptions and ColumnFamilyOptions to be passed to the EmbeddedRocksDBStateBackend.

Class Summary

Class	Description
AbstractRocksDBState<K,N,V>	Base class for State implementations that store state in a RocksDB database.
EmbeddedRocksDBStateBackend	A StateBackend that stores its state in an embedded RocksDB instance.
EmbeddedRocksDBStateBackendFactory	A factory that creates an EmbeddedRocksDBStateBackend from a configuration.
RocksDBCachingPriorityQueueSet<E extends HeapPriorityQueueElement>	A priority queue with set semantics, implemented on top of RocksDB.
RocksDBConfigurableOptions	This class contains the configuration options for the EmbeddedRocksDBStateBackend.
RocksDBIncrementalCheckpointUtils	Utils for RocksDB Incremental Checkpoint.
RocksDBIncrementalCheckpointUtils.RangeCheckResult	Helper class that represents the result of a range check of the actual keys in a RocksDB instance against the proclaimed key-group range of the instance.
RocksDBKeyedStateBackend<K>	An AbstractKeyedStateBackend that stores its state in RocksDB and serializes state to streams provided by a CheckpointStreamFactory upon checkpointing.
RocksDBKeyedStateBackend.RocksDbKvStateInfo	Rocks DB specific information about the k/v states.
RocksDBKeyedStateBackendBuilder<K>	Builder class for RocksDBKeyedStateBackend which handles all necessary initializations and clean ups.
RocksDBMemoryConfiguration	The settings regarding RocksDBs memory usage.
RocksDBMemoryControllerUtils	Utils to create Cache and WriteBufferManager which are used to control total memory usage of RocksDB.
RocksDBNativeMetricMonitor	A monitor which pulls {RocksDB} native metrics and forwards them to Flink's metric group.
RocksDBNativeMetricOptions	Enable which RocksDB metrics to forward to Flink's metrics reporter.
RocksDBOperationUtils	Utils for RocksDB Operations.
RocksDBOptions	Configuration options for the RocksDB backend.
RocksDBPriorityQueueConfig	The configuration of rocksDB priority queue state implementation.
RocksDBPriorityQueueSetFactory	Encapsulates the logic and resources in connection with creating priority queue state structures, for RocksDB backend.
RocksDBResourceContainer	The container for RocksDB resources, including predefined options, option factory and shared resource among instances.
RocksDBStateDataTransferHelper	Data transfer helper for RocksDBKeyedStateBackend.
RocksDBStateDownloader	Help class for downloading RocksDB state files.
RocksDBStateUploader	Help class for uploading RocksDB state files.
RocksDBWriteBatchWrapper	It's a wrapper class around RocksDB's WriteBatch for writing in bulk.
RocksIteratorWrapper	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.
StateHandleDownloadSpec	This class represents a download specification for the content of one IncrementalRemoteKeyedStateHandle to a target Path.
TreeOrderedSetCache	Implementation of a lexicographically ordered set of byte-arrays, based on a TreeSet.

Enum Summary

Enum	Description
EmbeddedRocksDBStateBackend.PriorityQueueStateType	The options to chose for the type of priority queue state.
PredefinedOptions	The PredefinedOptions are configuration settings for the EmbeddedRocksDBStateBackend.
RocksDBProperty	RocksDB properties that can be queried by Flink's metrics reporter.