| AbstractRocksDBState |
Base class for State implementations that store state in a RocksDB database.
|
| ConfigurableRocksDBOptionsFactory |
An interface for options factory that pick up additional parameters from a configuration.
|
| DefaultConfigurableOptionsFactory |
Deprecated.
|
| EmbeddedRocksDBStateBackend |
A StateBackend that stores its state in an embedded
RocksDB instance.
|
| EmbeddedRocksDBStateBackend.PriorityQueueStateType |
The options to chose for the type of priority queue state.
|
| PredefinedOptions |
|
| RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache |
Cache that is organized as an ordered set for byte-arrays.
|
| RocksDBKeyedStateBackend |
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.
|
| RocksDBMemoryConfiguration |
The settings regarding RocksDBs memory usage.
|
| RocksDBMemoryControllerUtils.RocksDBMemoryFactory |
Factory for Write Buffer Manager and Bock Cache.
|
| 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.
|
| RocksDBOptionsFactory |
|
| RocksDBPriorityQueueConfig |
The configuration of rocksDB priority queue state implementation.
|
| RocksDBProperty |
RocksDB properties that can be queried by Flink's metrics reporter.
|
| RocksDBResourceContainer |
The container for RocksDB resources, including predefined options, option factory and shared
resource among instances.
|
| RocksDBStateBackend |
Deprecated.
|
| RocksDBStateBackend.PriorityQueueStateType |
Deprecated.
|
| 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. |