Index (Flink : State backends : RocksDB 1.20.3-cp1 API)

A B C D E F G H I K L M N O P R S T U V W
All Classes All Packages

A

AbstractRocksDBState<K,N,V> - Class in org.apache.flink.contrib.streaming.state: Base class for State implementations that store state in a RocksDB database.
AbstractRocksDBState(ColumnFamilyHandle, TypeSerializer<N>, TypeSerializer<V>, V, RocksDBKeyedStateBackend<K>) - Constructor for class org.apache.flink.contrib.streaming.state.AbstractRocksDBState: Creates a new RocksDB backed state.
AbstractRocksStateKeysIterator<K> - Class in org.apache.flink.contrib.streaming.state.iterator: Base class for iterators over RocksDB column families.
AbstractRocksStateKeysIterator(RocksIteratorWrapper, String, TypeSerializer<K>, int, boolean) - Constructor for class org.apache.flink.contrib.streaming.state.iterator.AbstractRocksStateKeysIterator
ActualDelayedWriteRate - org.apache.flink.contrib.streaming.state.RocksDBProperty
add(byte[]) - Method in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache: Adds the given element, if it was not already contained.
add(byte[]) - Method in class org.apache.flink.contrib.streaming.state.TreeOrderedSetCache
add(E) - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
addAll(Collection<? extends E>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
addColumnFamilyOptionsToCloseLater(List<ColumnFamilyOptions>, ColumnFamilyHandle) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils
allocateRocksDBSharedResources(long, double, double, boolean, RocksDBMemoryControllerUtils.RocksDBMemoryFactory) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryControllerUtils: Allocate memory controllable RocksDB shared resources.
allocateSharedCachesIfConfigured(RocksDBMemoryConfiguration, Environment, double, Logger, RocksDBMemoryControllerUtils.RocksDBMemoryFactory) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils
ambiguousKeyPossible - Variable in class org.apache.flink.contrib.streaming.state.iterator.AbstractRocksStateKeysIterator
asyncSnapshot(RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources, long, long, CheckpointStreamFactory, CheckpointOptions) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy
asyncSnapshot(RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources, long, long, CheckpointStreamFactory, CheckpointOptions) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksNativeFullSnapshotStrategy

B

backend - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState: Backend that holds the actual RocksDB instance where we store state.
backendUID - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase: The state handle ids of all sst files materialized in snapshots for previous checkpoints.
BackgroundErrors - org.apache.flink.contrib.streaming.state.RocksDBProperty
beforeThePrefixBytes(byte[], byte[]) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBIncrementalCheckpointUtils: check whether the bytes is before prefixBytes in the character order.
BLOCK_CACHE_CAPACITY - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
BLOCK_CACHE_PINNED_USAGE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
BLOCK_CACHE_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
BLOCK_CACHE_USAGE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
BLOCK_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
BlockCacheCapacity - org.apache.flink.contrib.streaming.state.RocksDBProperty
BlockCachePinnedUsage - org.apache.flink.contrib.streaming.state.RocksDBProperty
BlockCacheUsage - org.apache.flink.contrib.streaming.state.RocksDBProperty
BLOOM_FILTER_BITS_PER_KEY - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
BLOOM_FILTER_BLOCK_BASED_MODE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
build() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder
build() - Method in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig.Builder
builder() - Static method in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig
Builder() - Constructor for class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig.Builder
buildWithPriorityQueueType(EmbeddedRocksDBStateBackend.PriorityQueueStateType) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueConfig
bulkLoadFromOrderedIterator(Iterator<byte[]>) - Method in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache: Clears the cache and adds up to maxSize() elements from the iterator to the cache.
bulkLoadFromOrderedIterator(Iterator<byte[]>) - Method in class org.apache.flink.contrib.streaming.state.TreeOrderedSetCache
byteArrayDataInputView - Variable in class org.apache.flink.contrib.streaming.state.iterator.AbstractRocksStateKeysIterator

C

calculateActualCacheCapacity(long, double) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryControllerUtils: Calculate the actual memory capacity of cache, which would be shared among rocksDB instance(s).
CHECKPOINT_TRANSFER_THREAD_NUM - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions: The number of threads used to transfer (download and upload) files in RocksDBStateBackend.
checkpointId - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation: Id for the current checkpoint.
checkpointStreamFactory - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation: Stream factory that creates the output streams to DFS.
chooseTheBestStateHandleForInitial(List<T>, KeyGroupRange, double) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBIncrementalCheckpointUtils: Choose the best state handle according to the RocksDBIncrementalCheckpointUtils.stateHandleEvaluator(KeyedStateHandle, KeyGroupRange, double) to init the initial db.
cleanupIncompleteSnapshot(CloseableRegistry, SnapshotDirectory) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
clear() - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
clipDBWithKeyGroupRange(RocksDB, List<ColumnFamilyHandle>, KeyGroupRange, KeyGroupRange, int, boolean) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBIncrementalCheckpointUtils: The method to clip the db instance according to the target key group range using the RocksDB.delete(ColumnFamilyHandle, byte[]).
close() - Method in class org.apache.flink.contrib.streaming.state.iterator.AbstractRocksStateKeysIterator
close() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksMultiStateKeysIterator
close() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksQueueIterator
close() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
close() - Method in interface org.apache.flink.contrib.streaming.state.iterator.SingleStateIterator
close() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBFullRestoreOperation
close() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBHeapTimersFullRestoreOperation
close() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBIncrementalRestoreOperation
close() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBNoneRestoreOperation
close() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDbKvStateInfo
close() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricMonitor
close() - Method in class org.apache.flink.contrib.streaming.state.RocksDBResourceContainer
close() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateDataTransferHelper
close() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateDownloader
close() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateUploader
close() - Method in class org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper
close() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
close() - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
close() - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy
close() - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksNativeFullSnapshotStrategy
close() - Method in interface org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionManager
COLUMN_FAMILY_AS_VARIABLE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
columnFamily - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState: The column family of this particular instance of state.
columnFamilyHandle - Variable in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDbKvStateInfo
COMPACTION_STYLE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
CompactionPending - org.apache.flink.contrib.streaming.state.RocksDBProperty
compactState(StateDescriptor<?, ?>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
COMPRESSION_PER_LEVEL - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
CONFIG_KEY_FORMAT - Static variable in enum org.apache.flink.contrib.streaming.state.RocksDBProperty
configCompactFilter(StateDescriptor<?, ?>, TypeSerializer<?>) - Method in class org.apache.flink.contrib.streaming.state.ttl.RocksDbTtlCompactFiltersManager
ConfigurableRocksDBOptionsFactory - Interface in org.apache.flink.contrib.streaming.state: An interface for options factory that pick up additional parameters from a configuration.
configure(ReadableConfig) - Method in interface org.apache.flink.contrib.streaming.state.ConfigurableRocksDBOptionsFactory: Creates a variant of the options factory that applies additional configuration parameters.
configure(ReadableConfig) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.

Creates a DefaultConfigurableOptionsFactory instance from a ReadableConfig.
configure(ReadableConfig, ClassLoader) - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Creates a copy of this state backend that uses the values defined in the configuration for fields where that were not yet specified in this state backend.
configure(ReadableConfig, ClassLoader) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Creates a copy of this state backend that uses the values defined in the configuration for fields where that were not yet specified in this state backend.
create(String, TypeSerializer<T>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
create(String, TypeSerializer<T>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueSetFactory
create(String, TypeSerializer<T>, boolean) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
create(String, TypeSerializer<T>, boolean) - Method in class org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueSetFactory
create(LinkedHashMap<String, RocksDBKeyedStateBackend.RocksDbKvStateInfo>, Map<String, HeapPriorityQueueSnapshotRestoreWrapper<?>>, RocksDB, ResourceGuard, KeyGroupRange, TypeSerializer<K>, int, StreamCompressionDecorator) - Static method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBFullSnapshotResources
create(RocksDB, RocksDBManualCompactionConfig, ExecutorService) - Static method in interface org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionManager
createCache(long, double) - Method in interface org.apache.flink.contrib.streaming.state.RocksDBMemoryControllerUtils.RocksDBMemoryFactory
createCheckpointStorage(JobID) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.
createColumnFamilyDescriptor(RegisteredStateMetaInfoBase, Function<String, ColumnFamilyOptions>, RocksDbTtlCompactFiltersManager, Long) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils: Creates a column descriptor for a state column family.
createColumnFamilyOptions(Function<String, ColumnFamilyOptions>, String) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils
createColumnOptions(ColumnFamilyOptions, Collection<AutoCloseable>) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
createColumnOptions(ColumnFamilyOptions, Collection<AutoCloseable>) - Method in interface org.apache.flink.contrib.streaming.state.RocksDBOptionsFactory: This method should set the additional options on top of the current options object.
createDBOptions(DBOptions, Collection<AutoCloseable>) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
createDBOptions(DBOptions, Collection<AutoCloseable>) - Method in interface org.apache.flink.contrib.streaming.state.RocksDBOptionsFactory: This method should set the additional options on top of the current options object.
createFromConfig(ReadableConfig, ClassLoader) - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackendFactory
createFromConfig(ReadableConfig, ClassLoader) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory: Deprecated.
createKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K>) - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend
createKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.
createKVStateIterator() - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBFullSnapshotResources
createLocalStateHandleForDownloadedState() - Method in class org.apache.flink.contrib.streaming.state.StateHandleDownloadSpec
createNativeMetricsOptions(RocksDBNativeMetricOptions) - Method in interface org.apache.flink.contrib.streaming.state.RocksDBOptionsFactory: This method should enable certain RocksDB metrics to be forwarded to Flink's metrics reporter.
createOperatorStateBackend(StateBackend.OperatorStateBackendParameters) - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend
createOperatorStateBackend(StateBackend.OperatorStateBackendParameters) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.
createOrUpdateInternalState(TypeSerializer<N>, StateDescriptor<S, SV>, StateSnapshotTransformer.StateSnapshotTransformFactory<SEV>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
createOrUpdateInternalState(TypeSerializer<N>, StateDescriptor<S, SV>, StateSnapshotTransformer.StateSnapshotTransformFactory<SEV>, boolean) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
createRangeCompactionTaskIfNeeded(RocksDB, Collection<ColumnFamilyHandle>, int, KeyGroupRange) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBIncrementalCheckpointUtils: Returns a range compaction task as runnable if any data in the SST files of the given DB exceeds the proclaimed key-group range.
createReadOptions(ReadOptions, Collection<AutoCloseable>) - Method in interface org.apache.flink.contrib.streaming.state.RocksDBOptionsFactory: This method should set the additional options on top of the current options object.
createStateInfo(RegisteredStateMetaInfoBase, RocksDB, Function<String, ColumnFamilyOptions>, RocksDbTtlCompactFiltersManager, Long) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils: Creates a state info from a new meta info to use with a k/v state.
createWriteBufferManager(long, Cache) - Method in interface org.apache.flink.contrib.streaming.state.RocksDBMemoryControllerUtils.RocksDBMemoryFactory
createWriteOptions(WriteOptions, Collection<AutoCloseable>) - Method in interface org.apache.flink.contrib.streaming.state.RocksDBOptionsFactory: This method should set the additional options on top of the current options object.
CurSizeActiveMemTable - org.apache.flink.contrib.streaming.state.RocksDBProperty
CurSizeAllMemTables - org.apache.flink.contrib.streaming.state.RocksDBProperty

D

dataInputView - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
dataOutputView - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
db - Variable in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend: Our RocksDB database, this is used by the actual subclasses of AbstractRocksDBState to store state.
db - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase: RocksDB instance from the backend.
DEFAULT - org.apache.flink.contrib.streaming.state.PredefinedOptions: Default options for all settings.
DEFAULT - Static variable in interface org.apache.flink.contrib.streaming.state.RocksDBMemoryControllerUtils.RocksDBMemoryFactory
DefaultConfigurableOptionsFactory - Class in org.apache.flink.contrib.streaming.state: Deprecated.
DefaultConfigurableOptionsFactory() - Constructor for class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
defaultValue - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
deserializeKey(byte[], DataInputDeserializer) - Method in class org.apache.flink.contrib.streaming.state.iterator.AbstractRocksStateKeysIterator
dispose() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend: Should only be called by one thread, and only after all accesses to the DB happened.
disposeAndClearRegisteredCompactionFactories() - Method in class org.apache.flink.contrib.streaming.state.ttl.RocksDbTtlCompactFiltersManager

E

EmbeddedRocksDBStateBackend - Class in org.apache.flink.contrib.streaming.state: A StateBackend that stores its state in an embedded RocksDB instance.
EmbeddedRocksDBStateBackend() - Constructor for class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Creates a new EmbeddedRocksDBStateBackend for storing local state.
EmbeddedRocksDBStateBackend(boolean) - Constructor for class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Creates a new EmbeddedRocksDBStateBackend for storing local state.
EmbeddedRocksDBStateBackend(TernaryBoolean) - Constructor for class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Creates a new EmbeddedRocksDBStateBackend for storing local state.
EmbeddedRocksDBStateBackend.PriorityQueueStateType - Enum in org.apache.flink.contrib.streaming.state: The options to chose for the type of priority queue state.
EmbeddedRocksDBStateBackendFactory - Class in org.apache.flink.contrib.streaming.state: A factory that creates an EmbeddedRocksDBStateBackend from a configuration.
EmbeddedRocksDBStateBackendFactory() - Constructor for class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackendFactory
EMPTY_PREVIOUS_SNAPSHOT - Static variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
enableActualDelayedWriteRate() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns the current actual delayed write rate.
enableBackgroundErrors() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns accumulated number of background errors.
enableBlockCacheCapacity() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns block cache capacity.
enableBlockCachePinnedUsage() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns the memory size for the entries being pinned in block cache.
enableBlockCacheUsage() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns the memory size for the entries residing in block cache.
enableCompactionPending() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns 1 if at least one compaction is pending; otherwise, returns 0.
enableCurSizeActiveMemTable() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns approximate size of active memtable (bytes).
enableCurSizeAllMemTables() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns approximate size of active and unflushed immutable memtables (bytes).
enableEstimateLiveDataSize() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns an estimate of the amount of live data in bytes.
enableEstimateNumKeys() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns estimated number of total keys in the active and unflushed immutable memtables and storage.
enableEstimatePendingCompactionBytes() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns estimated total number of bytes compaction needs to rewrite to get all levels down to under target size.
enableEstimateTableReadersMem() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns estimated memory used for reading SST tables, excluding memory used in block cache (e.g.,filter and index blocks).
enableIsWriteStopped() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns 1 if write has been stopped.
enableLiveSstFilesSize() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
enableMemTableFlushPending() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns 1 if a memtable flush is pending; otherwise, returns 0.
enableNativeStatistics(ConfigOption<Boolean>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
enableNumDeletesActiveMemTable() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns total number of delete entries in the active memtable.
enableNumDeletesImmMemTables() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns total number of delete entries in the unflushed immutable memtables.
enableNumEntriesActiveMemTable() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns total number of entries in the active memtable.
enableNumEntriesImmMemTables() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns total number of entries in the unflushed immutable memtables.
enableNumFilesAtLevel() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns the number of files per level.
enableNumImmutableMemTable() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns number of immutable memtables that have not yet been flushed.
enableNumLiveVersions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns number of live versions.
enableNumRunningCompactions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns the number of currently running compactions.
enableNumRunningFlushes() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns the number of currently running flushes.
enableNumSnapshots() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns number of unreleased snapshots of the database.
enableSizeAllMemTables() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns approximate size of active, unflushed immutable, and pinned immutable memtables (bytes).
enableTotalSstFilesSize() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns total size (bytes) of all SST files.
ESTIMATE_LIVE_DATA_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
ESTIMATE_NUM_KEYS - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
ESTIMATE_PENDING_COMPACTION_BYTES - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
ESTIMATE_TABLE_READERS_MEM - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
EstimateLiveDataSize - org.apache.flink.contrib.streaming.state.RocksDBProperty
EstimateNumKeys - org.apache.flink.contrib.streaming.state.RocksDBProperty
EstimatePendingCompactionBytes - org.apache.flink.contrib.streaming.state.RocksDBProperty
EstimateTableReadersMem - org.apache.flink.contrib.streaming.state.RocksDBProperty

F

findTheBestStateHandleForInitial(List<T>, KeyGroupRange, double) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBIncrementalCheckpointUtils: Choose the best state handle according to the RocksDBIncrementalCheckpointUtils.stateHandleEvaluator(KeyedStateHandle, KeyGroupRange, double) to init the initial db from the given lists and returns its index.
FIX_PER_SLOT_MEMORY_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions
FIX_PER_TM_MEMORY_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions
FLASH_SSD_OPTIMIZED - org.apache.flink.contrib.streaming.state.PredefinedOptions: Pre-defined options for Flash SSDs.
flush() - Method in class org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper
forThreadNum(int) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBStateDataTransferHelper
forThreadNumIfSpecified(int, ExecutorService) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBStateDataTransferHelper
from(ReadableConfig) - Static method in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig
fromConfig(ReadableConfig) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Creates a RocksDBNativeMetricOptions based on an external configuration.
fromConfiguration(Configuration) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration
fromOtherAndConfiguration(RocksDBMemoryConfiguration, ReadableConfig) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration: Derives a RocksDBMemoryConfiguration from another object and a configuration.
fromOtherAndConfiguration(RocksDBPriorityQueueConfig, ReadableConfig) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueConfig

G

getAsyncCompactAfterRestoreFuture() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBRestoreResult
getAsyncCompactAfterRestoreFuture() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
getBackendUID() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBRestoreResult
getCacheSize() - Method in class org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueSetFactory
getCheckpointBackend() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Gets the state backend that this RocksDB state backend uses to persist its bytes to.
getColumnOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBResourceContainer: Gets the RocksDB ColumnFamilyOptions to be used for all RocksDB instances.
getConfigKey() - Method in enum org.apache.flink.contrib.streaming.state.RocksDBProperty
getConfiguredOptions() - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
getDb() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBRestoreResult
getDbOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBResourceContainer: Gets the RocksDB DBOptions to be used for RocksDB instances.
getDbStoragePaths() - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Gets the configured local DB storage paths, or null, if none were configured.
getDbStoragePaths() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Gets the configured local DB storage paths, or null, if none were configured.
getDefault() - Static method in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig
getDefaultColumnFamilyHandle() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBRestoreResult
getDefaultValue() - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
getDescription() - Method in enum org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend.PriorityQueueStateType
getDescription() - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
getDownloadDestination() - Method in class org.apache.flink.contrib.streaming.state.StateHandleDownloadSpec
getExecutorService() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateDataTransferHelper
getFixedMemoryPerSlot() - Method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration: Gets the fixed amount of memory to be shared between all RocksDB instances (in all tasks and operators) of a slot.
getHighPriorityPoolRatio() - Method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration: Gets the fraction of the total memory to be used for high priority blocks like indexes, dictionaries, etc.
getInstanceRocksDBPath(File) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder
getKeyGroupPrefixBytes() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
getKeyGroupRange() - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBFullSnapshotResources
getKeys(String, N) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
getKeys(List<String>, N) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
getKeysAndNamespaces(String) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
getKeySerializer() - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBFullSnapshotResources
getKvStateId() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksQueueIterator
getKvStateId() - Method in interface org.apache.flink.contrib.streaming.state.iterator.SingleStateIterator
getLastCompletedCheckpointId() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBRestoreResult
getLocalSnapshot(StreamStateHandle, List<IncrementalKeyedStateHandle.HandleAndLocalPath>) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation
getMemoryConfiguration() - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Gets the memory configuration object, which offers settings to control RocksDB's memory usage.
getMetaInfoSnapshots() - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBFullSnapshotResources
getMonitorTickerTypes() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
getNativeMetricMonitor() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBRestoreResult
getNumberOfTransferingThreads() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.
Typo in method name. Use RocksDBStateBackend.getNumberOfTransferThreads() instead.
getNumberOfTransferThreads() - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Gets the number of threads used to transfer files while snapshotting/restoring.
getNumberOfTransferThreads() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Gets the number of threads used to transfer files while snapshotting/restoring.
getNumericalPropertyValue(RocksDB, ColumnFamilyHandle) - Method in enum org.apache.flink.contrib.streaming.state.RocksDBProperty
getPredefinedOptions() - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Gets the currently set predefined options for RocksDB.
getPredefinedOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Gets the currently set predefined options for RocksDB.
getPriorityQueueStateType() - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Gets the type of the priority queue state.
getPriorityQueueStateType() - Method in class org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueConfig: Gets the type of the priority queue state.
getPriorityQueueStateType() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Gets the type of the priority queue state.
getProperties() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
getReadOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
getReadOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBResourceContainer: Gets the RocksDB ReadOptions to be used for read operations.
getRestoredSstFiles() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBRestoreResult
getRocksDBOptions() - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Gets Options for the RocksDB instances.
getRocksDBOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Gets Options for the RocksDB instances.
getRocksDBPriorityQueueSetCacheSize() - Method in class org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueConfig: Gets the cache size of rocksDB priority queue set.
getRocksDBProperty() - Method in enum org.apache.flink.contrib.streaming.state.RocksDBProperty
getRocksIterator(RocksDB, ColumnFamilyHandle, ReadOptions) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils
getSerializedValue(byte[], TypeSerializer<K>, TypeSerializer<N>, TypeSerializer<V>) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
getStateHandle() - Method in class org.apache.flink.contrib.streaming.state.StateHandleDownloadSpec
getStateIncrementalVisitor(int) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
getStreamCompressionDecorator() - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBFullSnapshotResources
getUploaded(String) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.PreviousSnapshot
getWriteBatchSize() - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Gets the max batch size will be used in RocksDBWriteBatchWrapper.
getWriteBatchSize() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Gets the max batch size will be used in RocksDBWriteBatchWrapper.
getWriteBufferManagerCapacity() - Method in class org.apache.flink.contrib.streaming.state.RocksDBResourceContainer: Gets write buffer manager capacity.
getWriteBufferRatio() - Method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration: Gets the fraction of the total memory to be used for write buffers.
getWriteOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
getWriteOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBResourceContainer: Gets the RocksDB WriteOptions to be used for write operations.

H

hasNext() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksMultiStateKeysIterator
hasNext() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysAndNamespaceIterator
hasNext() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysIterator
HEAP - org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend.PriorityQueueStateType
HEAP - org.apache.flink.contrib.streaming.state.RocksDBStateBackend.PriorityQueueStateType: Deprecated.
HIGH_PRIORITY_POOL_RATIO - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions

I

INCREMENTAL_RESTORE_ASYNC_COMPACT_AFTER_RESCALE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
instanceBasePath - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase: Base path of the RocksDB instance.
IS_WRITE_STOPPED - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
isColumnFamilyAsVariable() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: {RocksDBNativeMetricMonitor} Whether to expose the column family as a variable..
isEmpty() - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
isEmpty() - Method in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache: Returns size() == 0.
isEmpty() - Method in class org.apache.flink.contrib.streaming.state.TreeOrderedSetCache
isEnabled() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: {RocksDBNativeMetricMonitor} is enabled if any property or ticker type is set.
isFull() - Method in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache: Returns size() == maxSize().
isFull() - Method in class org.apache.flink.contrib.streaming.state.TreeOrderedSetCache
isIncrementalCheckpointsEnabled() - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Gets whether incremental checkpoints are enabled for this state backend.
isIncrementalCheckpointsEnabled() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Gets whether incremental checkpoints are enabled for this state backend.
isMatchingNameSpace(byte[], int, byte[]) - Static method in class org.apache.flink.contrib.streaming.state.iterator.AbstractRocksStateKeysIterator
isNewKeyGroup() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
isNewKeyValueState() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
isSafeToReuseKVState() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
isSstDataInKeyGroupRange(RocksDB, int, KeyGroupRange) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBIncrementalCheckpointUtils: Returns true, if all entries in the sst files of the given DB is strictly within the expected key-group range for the DB.
isStatisticsEnabled() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
isUsingFixedMemoryPerSlot() - Method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration: Gets whether the state backend is configured to use a fixed amount of memory shared between all RocksDB instances (in all tasks and operators) of a slot.
isUsingManagedMemory() - Method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration: Gets whether the state backend is configured to use the managed memory of a slot for RocksDB.
isUsingPartitionedIndexFilters() - Method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration: Gets whether the state backend is configured to use partitioned index/filters for RocksDB.
isValid() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksQueueIterator
isValid() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
isValid() - Method in interface org.apache.flink.contrib.streaming.state.iterator.SingleStateIterator
isValid() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
IsWriteStopped - org.apache.flink.contrib.streaming.state.RocksDBProperty
iterator - Variable in class org.apache.flink.contrib.streaming.state.iterator.AbstractRocksStateKeysIterator
iterator() - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet

K

key() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksQueueIterator
key() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
key() - Method in interface org.apache.flink.contrib.streaming.state.iterator.SingleStateIterator
key() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
keyGroup() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
keyGroupPrefixBytes - Variable in class org.apache.flink.contrib.streaming.state.iterator.AbstractRocksStateKeysIterator
keyGroupPrefixBytes - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase: Number of bytes in the key-group prefix.
keyGroupRange - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase: The key-group range for the task.
keySerializer - Variable in class org.apache.flink.contrib.streaming.state.iterator.AbstractRocksStateKeysIterator
keySerializer - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase: The key serializer of the backend.
kvStateId() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
kvStateInformation - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase: Key/Value state meta info from the backend.

L

LEXICOGRAPHIC_BYTE_COMPARATOR - Static variable in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache: Comparator for byte arrays.
LiveSstFilesSize - org.apache.flink.contrib.streaming.state.RocksDBProperty
LOCAL_DIRECTORIES - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions: The local directory (on the TaskManager) where RocksDB puts its files.
localBackupDirectory - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation: Local directory for the RocksDB native backup.
localDirectoryName - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase: The local directory name of the current snapshot strategy.
localRecoveryConfig - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase: The configuration for local recovery.
LOG - Static variable in interface org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionManager
LOG_DIR - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
LOG_FILE_NUM - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
LOG_LEVEL - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
LOG_MAX_FILE_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions

M

materializeMetaData(CloseableRegistry, CloseableRegistry, List<StateMetaInfoSnapshot>, long, CheckpointStreamFactory) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
MAX_AUTO_COMPACTIONS - Static variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionOptions
MAX_BACKGROUND_THREADS - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
MAX_FILE_SIZE_TO_COMPACT - Static variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionOptions
MAX_FILES_TO_COMPACT - Static variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionOptions
MAX_OPEN_FILES - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
MAX_OUTPUT_FILE_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionOptions
MAX_PARALLEL_COMPACTIONS - Static variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionOptions
MAX_SIZE_LEVEL_BASE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
MAX_WRITE_BUFFER_NUMBER - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
maxAutoCompactions - Variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig
maxFileSizeToCompact - Variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig
maxFilesToCompact - Variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig
maxManualCompactions - Variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig
maxOutputFileSize - Variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig
maxSize() - Method in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache: Returns the maximum number of elements that can be stored in the cache.
maxSize() - Method in class org.apache.flink.contrib.streaming.state.TreeOrderedSetCache
MemTableFlushPending - org.apache.flink.contrib.streaming.state.RocksDBProperty
MERGE_OPERATOR_NAME - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend: The name of the merge operator in RocksDB.
METADATA_BLOCK_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
metaInfo - Variable in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDbKvStateInfo
METRICS_COLUMN_FAMILY_AS_VARIABLE_KEY - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
migrateSerializedValue(DataInputDeserializer, DataOutputSerializer, TypeSerializer<V>, TypeSerializer<V>) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
MIN_FILES_TO_COMPACT - Static variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionOptions
MIN_INTERVAL - Static variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionOptions
MIN_WRITE_BUFFER_NUMBER_TO_MERGE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
minFilesToCompact - Variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig
minInterval - Variable in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig
MONITOR_ACTUAL_DELAYED_WRITE_RATE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_BACKGROUND_ERRORS - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_BLOCK_CACHE_HIT - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_BLOCK_CACHE_MISS - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_BLOOM_FILTER_FULL_POSITIVE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_BLOOM_FILTER_FULL_TRUE_POSITIVE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_BLOOM_FILTER_USEFUL - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_BYTES_READ - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_BYTES_WRITTEN - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_COMPACTION_READ_BYTES - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_COMPACTION_WRITE_BYTES - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_CUR_SIZE_ACTIVE_MEM_TABLE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_CUR_SIZE_ALL_MEM_TABLE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_ITER_BYTES_READ - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_LIVE_SST_FILES_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_MEM_TABLE_FLUSH_PENDING - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_NUM_DELETES_ACTIVE_MEM_TABLE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_NUM_DELETES_IMM_MEM_TABLE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_NUM_ENTRIES_ACTIVE_MEM_TABLE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_NUM_ENTRIES_IMM_MEM_TABLES - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_NUM_FILES_AT_LEVEL - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_NUM_IMMUTABLE_MEM_TABLES - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_NUM_LIVE_VERSIONS - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_NUM_RUNNING_COMPACTIONS - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_NUM_RUNNING_FLUSHES - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_NUM_SNAPSHOTS - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_SIZE_ALL_MEM_TABLES - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_STALL_MICROS - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
MONITOR_TOTAL_SST_FILES_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions

N

NativeRocksDBSnapshotResources(SnapshotDirectory, RocksDBSnapshotStrategyBase.PreviousSnapshot, List<StateMetaInfoSnapshot>) - Constructor for class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources
next() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksMultiStateKeysIterator
next() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksQueueIterator
next() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysAndNamespaceIterator
next() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysIterator
next() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
next() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksTransformingIteratorWrapper
next() - Method in interface org.apache.flink.contrib.streaming.state.iterator.SingleStateIterator
next() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
NO_OP - Static variable in interface org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionManager
notifyCheckpointAborted(long) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
notifyCheckpointAborted(long) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy
notifyCheckpointAborted(long) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksNativeFullSnapshotStrategy
notifyCheckpointComplete(long) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
notifyCheckpointComplete(long) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy
notifyCheckpointComplete(long) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksNativeFullSnapshotStrategy
NumDeletesActiveMemTable - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumDeletesImmMemTables - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumEntriesActiveMemTable - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumEntriesImmMemTables - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumFilesAtLevel0 - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumFilesAtLevel1 - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumFilesAtLevel2 - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumFilesAtLevel3 - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumFilesAtLevel4 - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumFilesAtLevel5 - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumFilesAtLevel6 - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumImmutableMemTable - org.apache.flink.contrib.streaming.state.RocksDBProperty
numKeyValueStateEntries() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
NumLiveVersions - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumRunningCompactions - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumRunningFlushes - org.apache.flink.contrib.streaming.state.RocksDBProperty
NumSnapshots - org.apache.flink.contrib.streaming.state.RocksDBProperty

O

openDB(String, List<ColumnFamilyDescriptor>, List<ColumnFamilyHandle>, ColumnFamilyOptions, DBOptions) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils
OPTIONS_FACTORY - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions: The options factory class for RocksDB to create DBOptions and ColumnFamilyOptions.
org.apache.flink.contrib.streaming.state - package org.apache.flink.contrib.streaming.state
org.apache.flink.contrib.streaming.state.iterator - package org.apache.flink.contrib.streaming.state.iterator
org.apache.flink.contrib.streaming.state.restore - package org.apache.flink.contrib.streaming.state.restore
org.apache.flink.contrib.streaming.state.snapshot - package org.apache.flink.contrib.streaming.state.snapshot
org.apache.flink.contrib.streaming.state.sstmerge - package org.apache.flink.contrib.streaming.state.sstmerge
org.apache.flink.contrib.streaming.state.ttl - package org.apache.flink.contrib.streaming.state.ttl

P

peek() - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
peekFirst() - Method in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache: Returns the first element or null if empty.
peekFirst() - Method in class org.apache.flink.contrib.streaming.state.TreeOrderedSetCache
peekLast() - Method in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache: Returns the last element or null if empty.
peekLast() - Method in class org.apache.flink.contrib.streaming.state.TreeOrderedSetCache
poll() - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
pollFirst() - Method in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache: Returns and removes the first element or returns null if empty.
pollFirst() - Method in class org.apache.flink.contrib.streaming.state.TreeOrderedSetCache
pollLast() - Method in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache: Returns and removes the last element or returns null if empty.
pollLast() - Method in class org.apache.flink.contrib.streaming.state.TreeOrderedSetCache
PREDEFINED_OPTIONS - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions: The predefined settings for RocksDB DBOptions and ColumnFamilyOptions by Flink community.
PredefinedOptions - Enum in org.apache.flink.contrib.streaming.state: The PredefinedOptions are configuration settings for the EmbeddedRocksDBStateBackend.
prepareLocalSnapshotDirectory(long) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
prev() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksTransformingIteratorWrapper
prev() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
previousSnapshot - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources
PreviousSnapshot(Collection<IncrementalKeyedStateHandle.HandleAndLocalPath>) - Constructor for class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.PreviousSnapshot
put(ColumnFamilyHandle, byte[], byte[]) - Method in class org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper

R

refresh() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
register(RocksDBKeyedStateBackend.RocksDbKvStateInfo) - Method in interface org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionManager
registerKvStateInformation(Map<String, RocksDBKeyedStateBackend.RocksDbKvStateInfo>, RocksDBNativeMetricMonitor, String, RocksDBKeyedStateBackend.RocksDbKvStateInfo) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils
release() - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBFullSnapshotResources
release() - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources
remove(byte[]) - Method in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache: Removes the given element, if it is contained.
remove(byte[]) - Method in class org.apache.flink.contrib.streaming.state.TreeOrderedSetCache
remove(E) - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
remove(ColumnFamilyHandle, byte[]) - Method in class org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper
requiresLegacySynchronousTimerSnapshots(SnapshotType) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
resolveCheckpoint(String) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.
restore() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBFullRestoreOperation: Restores all key-groups data that is referenced by the passed state handles.
restore() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBHeapTimersFullRestoreOperation: Restores all key-groups data that is referenced by the passed state handles.
restore() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBIncrementalRestoreOperation: Root method that branches for different implementations of IncrementalKeyedStateHandle.
restore() - Method in class org.apache.flink.contrib.streaming.state.restore.RocksDBNoneRestoreOperation
restore() - Method in interface org.apache.flink.contrib.streaming.state.restore.RocksDBRestoreOperation: Restores state that was previously snapshot-ed from the provided state handles.
RESTORE_OVERLAP_FRACTION_THRESHOLD - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
ROCKSDB - org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend.PriorityQueueStateType
ROCKSDB - org.apache.flink.contrib.streaming.state.RocksDBStateBackend.PriorityQueueStateType: Deprecated.
ROCKSDB_TIMER_SERVICE_FACTORY_CACHE_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions: The cache size per key-group for ROCKSDB timer service factory implementation.
RocksDBCachingPriorityQueueSet<E extends org.apache.flink.runtime.state.heap.HeapPriorityQueueElement> - Class in org.apache.flink.contrib.streaming.state: A priority queue with set semantics, implemented on top of RocksDB.
RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache - Interface in org.apache.flink.contrib.streaming.state: Cache that is organized as an ordered set for byte-arrays.
RocksDBConfigurableOptions - Class in org.apache.flink.contrib.streaming.state: This class contains the configuration options for the EmbeddedRocksDBStateBackend.
RocksDBConfigurableOptions() - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
RocksDBFullRestoreOperation<K> - Class in org.apache.flink.contrib.streaming.state.restore: Encapsulates the process of restoring a RocksDB instance from a full snapshot.
RocksDBFullRestoreOperation(KeyGroupRange, ClassLoader, Map<String, RocksDBKeyedStateBackend.RocksDbKvStateInfo>, StateSerializerProvider<K>, File, DBOptions, Function<String, ColumnFamilyOptions>, RocksDBNativeMetricOptions, MetricGroup, Collection<KeyedStateHandle>, RocksDbTtlCompactFiltersManager, long, Long) - Constructor for class org.apache.flink.contrib.streaming.state.restore.RocksDBFullRestoreOperation
RocksDBFullSnapshotResources<K> - Class in org.apache.flink.contrib.streaming.state.snapshot: A FullSnapshotResources for the RocksDB backend.
RocksDBFullSnapshotResources(ResourceGuard.Lease, Snapshot, List<RocksDBKeyedStateBackend.RocksDbKvStateInfo>, List<HeapPriorityQueueStateSnapshot<?>>, List<StateMetaInfoSnapshot>, RocksDB, int, KeyGroupRange, TypeSerializer<K>, StreamCompressionDecorator) - Constructor for class org.apache.flink.contrib.streaming.state.snapshot.RocksDBFullSnapshotResources
RocksDBHeapTimersFullRestoreOperation<K> - Class in org.apache.flink.contrib.streaming.state.restore: Encapsulates the process of restoring a RocksDB instance from a full snapshot.
RocksDBHeapTimersFullRestoreOperation(KeyGroupRange, int, ClassLoader, Map<String, RocksDBKeyedStateBackend.RocksDbKvStateInfo>, LinkedHashMap<String, HeapPriorityQueueSnapshotRestoreWrapper<?>>, HeapPriorityQueueSetFactory, StateSerializerProvider<K>, File, DBOptions, Function<String, ColumnFamilyOptions>, RocksDBNativeMetricOptions, MetricGroup, Collection<KeyedStateHandle>, RocksDbTtlCompactFiltersManager, long, Long) - Constructor for class org.apache.flink.contrib.streaming.state.restore.RocksDBHeapTimersFullRestoreOperation
RocksDBIncrementalCheckpointUtils - Class in org.apache.flink.contrib.streaming.state: Utils for RocksDB Incremental Checkpoint.
RocksDBIncrementalCheckpointUtils() - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBIncrementalCheckpointUtils
RocksDBIncrementalRestoreOperation<K> - Class in org.apache.flink.contrib.streaming.state.restore: Encapsulates the process of restoring a RocksDB instance from an incremental snapshot.
RocksDBIncrementalRestoreOperation(String, KeyGroupRange, int, int, CloseableRegistry, ClassLoader, Map<String, RocksDBKeyedStateBackend.RocksDbKvStateInfo>, StateSerializerProvider<K>, File, File, DBOptions, Function<String, ColumnFamilyOptions>, RocksDBNativeMetricOptions, MetricGroup, StateBackend.CustomInitializationMetrics, Collection<IncrementalKeyedStateHandle>, RocksDbTtlCompactFiltersManager, long, Long, double, boolean, boolean, boolean, ExecutorService) - Constructor for class org.apache.flink.contrib.streaming.state.restore.RocksDBIncrementalRestoreOperation
RocksDBKeyedStateBackend<K> - Class in org.apache.flink.contrib.streaming.state: An AbstractKeyedStateBackend that stores its state in RocksDB and serializes state to streams provided by a CheckpointStreamFactory upon checkpointing.
RocksDBKeyedStateBackend(ClassLoader, File, RocksDBResourceContainer, Function<String, ColumnFamilyOptions>, TaskKvStateRegistry, TypeSerializer<K>, ExecutionConfig, TtlTimeProvider, LatencyTrackingStateConfig, RocksDB, LinkedHashMap<String, RocksDBKeyedStateBackend.RocksDbKvStateInfo>, Map<String, HeapPriorityQueueSnapshotRestoreWrapper<?>>, int, CloseableRegistry, StreamCompressionDecorator, ResourceGuard, RocksDBSnapshotStrategyBase<K, ?>, RocksDBWriteBatchWrapper, ColumnFamilyHandle, RocksDBNativeMetricMonitor, SerializedCompositeKeyBuilder<K>, PriorityQueueSetFactory, RocksDbTtlCompactFiltersManager, InternalKeyContext<K>, long, CompletableFuture<Void>, RocksDBManualCompactionManager) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
RocksDBKeyedStateBackend.RocksDbKvStateInfo - Class in org.apache.flink.contrib.streaming.state: Rocks DB specific information about the k/v states.
RocksDBKeyedStateBackendBuilder<K> - Class in org.apache.flink.contrib.streaming.state: Builder class for RocksDBKeyedStateBackend which handles all necessary initializations and clean ups.
RocksDBKeyedStateBackendBuilder(String, ClassLoader, File, RocksDBResourceContainer, Function<String, ColumnFamilyOptions>, TaskKvStateRegistry, TypeSerializer<K>, int, KeyGroupRange, ExecutionConfig, LocalRecoveryConfig, RocksDBPriorityQueueConfig, TtlTimeProvider, LatencyTrackingStateConfig, MetricGroup, StateBackend.CustomInitializationMetrics, Collection<KeyedStateHandle>, StreamCompressionDecorator, CloseableRegistry) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder
RocksDbKvStateInfo(ColumnFamilyHandle, RegisteredStateMetaInfoBase) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDbKvStateInfo
RocksDBManualCompactionConfig - Class in org.apache.flink.contrib.streaming.state.sstmerge: Configuration for RocksDBManualCompactionManager.
RocksDBManualCompactionConfig(long, int, MemorySize, int, int, MemorySize, int) - Constructor for class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig
RocksDBManualCompactionConfig.Builder - Class in org.apache.flink.contrib.streaming.state.sstmerge: Builder for RocksDBManualCompactionConfig.
RocksDBManualCompactionManager - Interface in org.apache.flink.contrib.streaming.state.sstmerge: Manages compactions of small and disjoint RocksDB SST files that otherwise would not be merged to reduce write amplification.
RocksDBManualCompactionOptions - Class in org.apache.flink.contrib.streaming.state.sstmerge: Configuration options for manual compaction for the RocksDB backend.
RocksDBManualCompactionOptions() - Constructor for class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionOptions
RocksDBMemoryConfiguration - Class in org.apache.flink.contrib.streaming.state: The settings regarding RocksDBs memory usage.
RocksDBMemoryConfiguration() - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration
RocksDBMemoryControllerUtils - Class in org.apache.flink.contrib.streaming.state: Utils to create Cache and WriteBufferManager which are used to control total memory usage of RocksDB.
RocksDBMemoryControllerUtils() - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBMemoryControllerUtils
RocksDBMemoryControllerUtils.RocksDBMemoryFactory - Interface in org.apache.flink.contrib.streaming.state: Factory for Write Buffer Manager and Bock Cache.
RocksDBNativeMetricMonitor - Class in org.apache.flink.contrib.streaming.state: A monitor which pulls {RocksDB} native metrics and forwards them to Flink's metric group.
RocksDBNativeMetricMonitor(RocksDBNativeMetricOptions, MetricGroup, RocksDB, Statistics) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricMonitor
RocksDBNativeMetricOptions - Class in org.apache.flink.contrib.streaming.state: Enable which RocksDB metrics to forward to Flink's metrics reporter.
RocksDBNativeMetricOptions() - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
RocksDBNoneRestoreOperation<K> - Class in org.apache.flink.contrib.streaming.state.restore: Encapsulates the process of initiating a RocksDB instance without restore.
RocksDBNoneRestoreOperation(Map<String, RocksDBKeyedStateBackend.RocksDbKvStateInfo>, File, DBOptions, Function<String, ColumnFamilyOptions>, RocksDBNativeMetricOptions, MetricGroup, RocksDbTtlCompactFiltersManager, Long) - Constructor for class org.apache.flink.contrib.streaming.state.restore.RocksDBNoneRestoreOperation
RocksDBOperationUtils - Class in org.apache.flink.contrib.streaming.state: Utils for RocksDB Operations.
RocksDBOperationUtils() - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils
RocksDBOptions - Class in org.apache.flink.contrib.streaming.state: Configuration options for the RocksDB backend.
RocksDBOptions() - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBOptions
RocksDBOptionsFactory - Interface in org.apache.flink.contrib.streaming.state: A factory for DBOptions and ColumnFamilyOptions to be passed to the EmbeddedRocksDBStateBackend.
RocksDBPriorityQueueConfig - Class in org.apache.flink.contrib.streaming.state: The configuration of rocksDB priority queue state implementation.
RocksDBPriorityQueueConfig() - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueConfig
RocksDBPriorityQueueConfig(EmbeddedRocksDBStateBackend.PriorityQueueStateType, int) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueConfig
RocksDBPriorityQueueSetFactory - Class in org.apache.flink.contrib.streaming.state: Encapsulates the logic and resources in connection with creating priority queue state structures, for RocksDB backend.
RocksDBProperty - Enum in org.apache.flink.contrib.streaming.state: RocksDB properties that can be queried by Flink's metrics reporter.
RocksDBResourceContainer - Class in org.apache.flink.contrib.streaming.state: The container for RocksDB resources, including predefined options, option factory and shared resource among instances.
RocksDBResourceContainer() - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBResourceContainer
RocksDBResourceContainer(ReadableConfig, PredefinedOptions, RocksDBOptionsFactory, OpaqueMemoryResource<RocksDBSharedResources>, File, boolean) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBResourceContainer
RocksDBResourceContainer(PredefinedOptions, RocksDBOptionsFactory) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBResourceContainer
RocksDBResourceContainer(PredefinedOptions, RocksDBOptionsFactory, OpaqueMemoryResource<RocksDBSharedResources>) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBResourceContainer
rocksDBResourceGuard - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase: Resource guard for the RocksDB instance.
RocksDBRestoreOperation - Interface in org.apache.flink.contrib.streaming.state.restore: Interface for RocksDB restore.
RocksDBRestoreResult - Class in org.apache.flink.contrib.streaming.state.restore: Entity holding result of RocksDB instance restore.
RocksDBRestoreResult(RocksDB, ColumnFamilyHandle, RocksDBNativeMetricMonitor, long, UUID, SortedMap<Long, Collection<IncrementalKeyedStateHandle.HandleAndLocalPath>>, CompletableFuture<Void>) - Constructor for class org.apache.flink.contrib.streaming.state.restore.RocksDBRestoreResult
RocksDBSnapshotOperation(long, CheckpointStreamFactory, SnapshotDirectory, List<StateMetaInfoSnapshot>) - Constructor for class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation
RocksDBSnapshotStrategyBase<K,R extends org.apache.flink.runtime.state.SnapshotResources> - Class in org.apache.flink.contrib.streaming.state.snapshot: Abstract base class for SnapshotStrategy implementations for RocksDB state backend.
RocksDBSnapshotStrategyBase(String, RocksDB, ResourceGuard, TypeSerializer<K>, LinkedHashMap<String, RocksDBKeyedStateBackend.RocksDbKvStateInfo>, KeyGroupRange, int, LocalRecoveryConfig, File, UUID) - Constructor for class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources - Class in org.apache.flink.contrib.streaming.state.snapshot: A SnapshotResources for native rocksdb snapshot.
RocksDBSnapshotStrategyBase.PreviousSnapshot - Class in org.apache.flink.contrib.streaming.state.snapshot: Previous snapshot with uploaded sst files.
RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation - Class in org.apache.flink.contrib.streaming.state.snapshot: Common operation in native rocksdb snapshot result supplier.
RocksDBStateBackend - Class in org.apache.flink.contrib.streaming.state: Deprecated.
RocksDBStateBackend(String) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Creates a new RocksDBStateBackend that stores its checkpoint data in the file system and location defined by the given URI.
RocksDBStateBackend(String, boolean) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Creates a new RocksDBStateBackend that stores its checkpoint data in the file system and location defined by the given URI.
RocksDBStateBackend(URI) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Creates a new RocksDBStateBackend that stores its checkpoint data in the file system and location defined by the given URI.
RocksDBStateBackend(URI, boolean) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Creates a new RocksDBStateBackend that stores its checkpoint data in the file system and location defined by the given URI.
RocksDBStateBackend(AbstractStateBackend) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.
Use RocksDBStateBackend(StateBackend) instead.
RocksDBStateBackend(AbstractStateBackend, boolean) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.
Use RocksDBStateBackend(StateBackend, TernaryBoolean) instead.
RocksDBStateBackend(StateBackend) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Creates a new RocksDBStateBackend that uses the given state backend to store its checkpoint data streams.
RocksDBStateBackend(StateBackend, TernaryBoolean) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Creates a new RocksDBStateBackend that uses the given state backend to store its checkpoint data streams.
RocksDBStateBackend.PriorityQueueStateType - Enum in org.apache.flink.contrib.streaming.state: Deprecated.
RocksDBStateBackendFactory - Class in org.apache.flink.contrib.streaming.state: Deprecated.
RocksDBStateBackendFactory() - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory: Deprecated.
RocksDBStateDataTransferHelper - Class in org.apache.flink.contrib.streaming.state: Data transfer helper for RocksDBKeyedStateBackend.
RocksDBStateDownloader - Class in org.apache.flink.contrib.streaming.state: Help class for downloading RocksDB state files.
RocksDBStateDownloader(int) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateDownloader
RocksDBStateDownloader(RocksDBStateDataTransferHelper) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateDownloader
RocksDBStateUploader - Class in org.apache.flink.contrib.streaming.state: Help class for uploading RocksDB state files.
RocksDBStateUploader(int) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateUploader
RocksDBStateUploader(RocksDBStateDataTransferHelper) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateUploader
RocksDbTtlCompactFiltersManager - Class in org.apache.flink.contrib.streaming.state.ttl: RocksDB compaction filter utils for state with TTL.
RocksDbTtlCompactFiltersManager(TtlTimeProvider) - Constructor for class org.apache.flink.contrib.streaming.state.ttl.RocksDbTtlCompactFiltersManager
RocksDBWriteBatchWrapper - Class in org.apache.flink.contrib.streaming.state: It's a wrapper class around RocksDB's WriteBatch for writing in bulk.
RocksDBWriteBatchWrapper(RocksDB, long) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper
RocksDBWriteBatchWrapper(RocksDB, WriteOptions) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper
RocksDBWriteBatchWrapper(RocksDB, WriteOptions, int, long) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper
RocksDBWriteBatchWrapper(RocksDB, WriteOptions, long) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper
RocksIncrementalSnapshotStrategy<K> - Class in org.apache.flink.contrib.streaming.state.snapshot: Snapshot strategy for RocksDBKeyedStateBackend that is based on RocksDB's native checkpoints and creates incremental snapshots.
RocksIncrementalSnapshotStrategy(RocksDB, ResourceGuard, TypeSerializer<K>, LinkedHashMap<String, RocksDBKeyedStateBackend.RocksDbKvStateInfo>, KeyGroupRange, int, LocalRecoveryConfig, File, UUID, SortedMap<Long, Collection<IncrementalKeyedStateHandle.HandleAndLocalPath>>, RocksDBStateUploader, long) - Constructor for class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy
RocksIteratorWrapper - Class in org.apache.flink.contrib.streaming.state: 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.
RocksIteratorWrapper(RocksIterator) - Constructor for class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
RocksMultiStateKeysIterator<K> - Class in org.apache.flink.contrib.streaming.state.iterator: Adapter class to bridge between RocksIteratorWrapper and Iterator to iterate over the keys.
RocksMultiStateKeysIterator(List<RocksIteratorWrapper>, List<String>, TypeSerializer<K>, int, List<Boolean>, byte[]) - Constructor for class org.apache.flink.contrib.streaming.state.iterator.RocksMultiStateKeysIterator
RocksNativeFullSnapshotStrategy<K> - Class in org.apache.flink.contrib.streaming.state.snapshot: Snapshot strategy for RocksDBKeyedStateBackend based on RocksDB's native checkpoints and creates full snapshots.
RocksNativeFullSnapshotStrategy(RocksDB, ResourceGuard, TypeSerializer<K>, LinkedHashMap<String, RocksDBKeyedStateBackend.RocksDbKvStateInfo>, KeyGroupRange, int, LocalRecoveryConfig, File, UUID, RocksDBStateUploader) - Constructor for class org.apache.flink.contrib.streaming.state.snapshot.RocksNativeFullSnapshotStrategy
RocksQueueIterator - Class in org.apache.flink.contrib.streaming.state.iterator: An iterator over heap timers that produces rocks compatible binary format.
RocksQueueIterator(HeapPriorityQueueStateSnapshot<?>, KeyGroupRange, int, int) - Constructor for class org.apache.flink.contrib.streaming.state.iterator.RocksQueueIterator
RocksSnapshotUtil - Class in org.apache.flink.contrib.streaming.state.snapshot: Utility methods and constants around RocksDB creating and restoring snapshots for RocksDBKeyedStateBackend.
RocksStateKeysAndNamespaceIterator<K,N> - Class in org.apache.flink.contrib.streaming.state.iterator: Adapter class to bridge between RocksIteratorWrapper and Iterator to iterate over the keys and namespaces.
RocksStateKeysAndNamespaceIterator(RocksIteratorWrapper, String, TypeSerializer<K>, TypeSerializer<N>, int, boolean) - Constructor for class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysAndNamespaceIterator
RocksStateKeysIterator<K> - Class in org.apache.flink.contrib.streaming.state.iterator: Adapter class to bridge between RocksIteratorWrapper and Iterator to iterate over the keys.
RocksStateKeysIterator(RocksIteratorWrapper, String, TypeSerializer<K>, int, boolean, byte[]) - Constructor for class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysIterator
RocksStatesPerKeyGroupMergeIterator - Class in org.apache.flink.contrib.streaming.state.iterator: Iterator that merges multiple RocksDB iterators to partition all states into contiguous key-groups.
RocksStatesPerKeyGroupMergeIterator(CloseableRegistry, List<Tuple2<RocksIteratorWrapper, Integer>>, List<SingleStateIterator>, int) - Constructor for class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator: Creates a new RocksStatesPerKeyGroupMergeIterator.
RocksTransformingIteratorWrapper - Class in org.apache.flink.contrib.streaming.state.iterator: Wrapper around RocksIterator that applies a given StateSnapshotTransformer to the elements during the iteration.
RocksTransformingIteratorWrapper(RocksIterator, StateSnapshotTransformer<byte[]>) - Constructor for class org.apache.flink.contrib.streaming.state.iterator.RocksTransformingIteratorWrapper

S

savepoint() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
seek(byte[]) - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
seek(ByteBuffer) - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
seekForPrev(byte[]) - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
seekForPrev(ByteBuffer) - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
seekToFirst() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksTransformingIteratorWrapper
seekToFirst() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
seekToLast() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksTransformingIteratorWrapper
seekToLast() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
setAndRegisterCompactFilterIfStateTtl(RegisteredStateMetaInfoBase, ColumnFamilyOptions) - Method in class org.apache.flink.contrib.streaming.state.ttl.RocksDbTtlCompactFiltersManager
setBlockCacheSize(String) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setBlockSize(String) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setBloomFilterBitsPerKey(double) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setBloomFilterBlockBasedMode(boolean) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setColumnFamilyAsVariable(boolean) - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions: Returns the column family as variable.
setCompactionStyle(CompactionStyle) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setCurrentKey(K) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
setCurrentNamespace(N) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
setDbStoragePath(String) - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Sets the path where the RocksDB local database files should be stored on the local file system.
setDbStoragePath(String) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Sets the path where the RocksDB local database files should be stored on the local file system.
setDbStoragePaths(String...) - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Sets the directories in which the local RocksDB database puts its files (like SST and metadata files).
setDbStoragePaths(String...) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Sets the directories in which the local RocksDB database puts its files (like SST and metadata files).
setDefaultValue(V) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
setFixedMemoryPerSlot(String) - Method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration: Configures RocksDB to use a fixed amount of memory shared between all instances (operators) in a slot.
setFixedMemoryPerSlot(MemorySize) - Method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration: Configures RocksDB to use a fixed amount of memory shared between all instances (operators) in a slot.
setHighPriorityPoolRatio(double) - Method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration: Sets the fraction of the total memory to be used for high priority blocks like indexes, dictionaries, etc.
setLogDir(String) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.

The directory for RocksDB's logging files.
setLogFileNum(int) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.

The maximum number of files RocksDB should keep for logging.
setLogLevel(InfoLogLevel) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setManualCompactionConfig(RocksDBManualCompactionConfig) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder
setMaxAutoCompactions(int) - Method in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig.Builder
setMaxBackgroundThreads(int) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setMaxFileSizeToCompact(MemorySize) - Method in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig.Builder
setMaxFilesToCompact(int) - Method in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig.Builder
setMaxLogFileSize(String) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.

The maximum size of RocksDB's file used for logging.
setMaxOpenFiles(int) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setMaxOutputFileSize(MemorySize) - Method in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig.Builder
setMaxParallelCompactions(int) - Method in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig.Builder
setMaxSizeLevelBase(String) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setMaxWriteBufferNumber(int) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setMetadataBlockSize(String) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setMinFilesToCompact(int) - Method in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig.Builder
setMinInterval(long) - Method in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig.Builder
setMinWriteBufferNumberToMerge(int) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setNamespaceSerializer(TypeSerializer<N>) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
setNumberOfTransferingThreads(int) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.
Typo in method name. Use RocksDBStateBackend.setNumberOfTransferThreads(int) instead.
setNumberOfTransferThreads(int) - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Sets the number of threads used to transfer files while snapshotting/restoring.
setNumberOfTransferThreads(int) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Sets the number of threads used to transfer files while snapshotting/restoring.
setPredefinedOptions(PredefinedOptions) - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Sets the predefined options for RocksDB.
setPredefinedOptions(PredefinedOptions) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Sets the predefined options for RocksDB.
setPriorityQueueStateType(EmbeddedRocksDBStateBackend.PriorityQueueStateType) - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Sets the type of the priority queue state.
setPriorityQueueStateType(EmbeddedRocksDBStateBackend.PriorityQueueStateType) - Method in class org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueConfig
setPriorityQueueStateType(RocksDBStateBackend.PriorityQueueStateType) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Sets the type of the priority queue state.
setRocksDBMemoryFactory(RocksDBMemoryControllerUtils.RocksDBMemoryFactory) - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Set RocksDBMemoryFactory.
setRocksDBOptions(RocksDBOptionsFactory) - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Sets Options for the RocksDB instances.
setRocksDBOptions(RocksDBOptionsFactory) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Sets Options for the RocksDB instances.
setTargetFileSizeBase(String) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setUseBloomFilter(boolean) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setUseDynamicLevelSize(boolean) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
setUseManagedMemory(boolean) - Method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration: Configures RocksDB to use the managed memory of a slot.
setValueSerializer(TypeSerializer<V>) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
setWriteBatchSize(long) - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend: Sets the max batch size will be used in RocksDBWriteBatchWrapper, no positive value will disable memory size controller, just use item count controller.
setWriteBatchSize(long) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.

Sets the max batch size will be used in RocksDBWriteBatchWrapper, no positive value will disable memory size controller, just use item count controller.
setWriteBufferRatio(double) - Method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration: Sets the fraction of the total memory to be used for write buffers.
setWriteBufferSize(String) - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
SingleStateIterator - Interface in org.apache.flink.contrib.streaming.state.iterator: An interface for iterating over a single state in a RocksDB state backend.
size() - Method in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache: Returns the number of contained elements.
size() - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet: This implementation comes at a relatively high cost per invocation.
size() - Method in class org.apache.flink.contrib.streaming.state.TreeOrderedSetCache
SizeAllMemTables - org.apache.flink.contrib.streaming.state.RocksDBProperty
snapshot(long, long, CheckpointStreamFactory, CheckpointOptions) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend: Triggers an asynchronous snapshot of the keyed state backend from RocksDB.
snapshotDirectory - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources
snapshotMetaData(long, List<StateMetaInfoSnapshot>) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
snapshotMetaData(long, List<StateMetaInfoSnapshot>) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy
snapshotMetaData(long, List<StateMetaInfoSnapshot>) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksNativeFullSnapshotStrategy
SPINNING_DISK_OPTIMIZED - org.apache.flink.contrib.streaming.state.PredefinedOptions: Pre-defined options for regular spinning hard disks.
SPINNING_DISK_OPTIMIZED_HIGH_MEM - org.apache.flink.contrib.streaming.state.PredefinedOptions: Pre-defined options for better performance on regular spinning hard disks, at the cost of a higher memory consumption.
SST_FILE_SUFFIX - Static variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksSnapshotUtil: File suffix of sstable files.
start() - Method in interface org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionManager
state - Variable in class org.apache.flink.contrib.streaming.state.iterator.AbstractRocksStateKeysIterator
StateHandleDownloadSpec - Class in org.apache.flink.contrib.streaming.state: This class represents a download specification for the content of one IncrementalRemoteKeyedStateHandle to a target Path.
StateHandleDownloadSpec(IncrementalRemoteKeyedStateHandle, Path) - Constructor for class org.apache.flink.contrib.streaming.state.StateHandleDownloadSpec
stateMetaInfoSnapshots - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources
stateMetaInfoSnapshots - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation: The state meta data.
status() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
supportsNoClaimRestoreMode() - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend
supportsNoClaimRestoreMode() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.
supportsSavepointFormat(SavepointFormatType) - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend
supportsSavepointFormat(SavepointFormatType) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.
syncPrepareResources(long) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase

T

TARGET_FILE_SIZE_BASE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
TIMER_SERVICE_FACTORY - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions: Choice of timer service implementation.
tmpResourcesRegistry - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation
toString() - Method in class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory: Deprecated.
toString() - Method in class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend
toString() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend: Deprecated.
toString() - Method in class org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig
toString() - Method in class org.apache.flink.contrib.streaming.state.StateHandleDownloadSpec
TotalSstFilesSize - org.apache.flink.contrib.streaming.state.RocksDBProperty
TRACK_COMPACTION_PENDING - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
transferAllStateDataToDirectory(Collection<StateHandleDownloadSpec>, CloseableRegistry) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateDownloader: Transfer all state data to the target directory, as specified in the download requests.
TreeOrderedSetCache - Class in org.apache.flink.contrib.streaming.state: Implementation of a lexicographically ordered set of byte-arrays, based on a TreeSet.

U

uploadFilesToCheckpointFs(List<Path>, CheckpointStreamFactory, CheckpointedStateScope, CloseableRegistry, CloseableRegistry) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateUploader: Upload all the files to checkpoint fileSystem using specified number of threads.
USE_BLOOM_FILTER - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
USE_DELETE_FILES_IN_RANGE_DURING_RESCALING - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
USE_DYNAMIC_LEVEL_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
USE_INGEST_DB_RESTORE_MODE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
USE_MANAGED_MEMORY - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions
USE_PARTITIONED_INDEX_FILTERS - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions

V

validate() - Method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration: Validates if the configured options are valid with respect to one another.
value() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksQueueIterator
value() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
value() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksTransformingIteratorWrapper
value() - Method in interface org.apache.flink.contrib.streaming.state.iterator.SingleStateIterator
value() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
valueOf(String) - Static method in enum org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend.PriorityQueueStateType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.contrib.streaming.state.PredefinedOptions: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.contrib.streaming.state.RocksDBProperty: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.contrib.streaming.state.RocksDBStateBackend.PriorityQueueStateType: Deprecated.

Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend.PriorityQueueStateType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.contrib.streaming.state.PredefinedOptions: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.contrib.streaming.state.RocksDBProperty: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.contrib.streaming.state.RocksDBStateBackend.PriorityQueueStateType: Deprecated.

Returns an array containing the constants of this enum type, in the order they are declared.

W

WRITE_BATCH_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
WRITE_BUFFER_RATIO - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions
WRITE_BUFFER_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions
writeOptions - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

A B C D E F G H I K L M N O P R S T U V W
All Classes All Packages