Class and Description |
---|
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
The
PredefinedOptions are configuration settings for the EmbeddedRocksDBStateBackend . |
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.
|
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 |
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. |
Class and Description |
---|
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. |
Class and Description |
---|
RocksDBKeyedStateBackend.RocksDbKvStateInfo
Rocks DB specific information about the k/v states.
|
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.
|
Class and Description |
---|
RocksDBKeyedStateBackend.RocksDbKvStateInfo
Rocks DB specific information about the k/v states.
|
RocksDBStateUploader
Help class for uploading RocksDB state files.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.