Skip navigation links
A B C D E F G H I K L M N O P R S T V W 

A

AbstractRocksDBState<K,N,V,S extends org.apache.flink.api.common.state.State> - 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.
add(E) - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
 
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
 
addAll(Collection<? extends E>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
 

B

backend - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
Backend that holds the actual RocksDB instance where we store state.
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
 

C

cancelStreamRegistry - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
A CloseableRegistry that will be closed when the task is cancelled.
clear() - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
 
clearMetaDataFollowsFlag(byte[]) - Static method in class org.apache.flink.contrib.streaming.state.snapshot.RocksSnapshotUtil
 
close() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysIterator
 
close() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
 
close() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricMonitor
 
close() - Method in class org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper
 
close() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
 
columnFamily - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
The column family of this particular instance of state.
computeRequiredBytesInKeyGroupPrefix(int) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils
 
configure(Configuration) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
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
 
createCheckpointStorage(JobID) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
 
createColumnOptions(ColumnFamilyOptions) - Method in interface org.apache.flink.contrib.streaming.state.OptionsFactory
This method should set the additional options on top of the current options object.
createColumnOptions() - Method in enum org.apache.flink.contrib.streaming.state.PredefinedOptions
Creates the ColumnFamilyOptionsfor this pre-defined setting.
createDBOptions(DBOptions) - Method in interface org.apache.flink.contrib.streaming.state.OptionsFactory
This method should set the additional options on top of the current options object.
createDBOptions() - Method in enum org.apache.flink.contrib.streaming.state.PredefinedOptions
Creates the DBOptionsfor this pre-defined setting.
createFromConfig(Configuration) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory
 
createInternalState(TypeSerializer<N>, StateDescriptor<S, SV>, StateSnapshotTransformer.StateSnapshotTransformFactory<SEV>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
 
createKeyedStateBackend(Environment, JobID, String, TypeSerializer<K>, int, KeyGroupRange, TaskKvStateRegistry, TtlTimeProvider, MetricGroup) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
 
createNativeMetricsOptions(RocksDBNativeMetricOptions) - Method in interface org.apache.flink.contrib.streaming.state.OptionsFactory
This method should enable certain RocksDB metrics to be forwarded to Flink's metrics reporter.
createOperatorStateBackend(Environment, String) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
 

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.
defaultValue - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
 
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.
doSnapshot(long, long, CheckpointStreamFactory, CheckpointOptions) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
This method implements the concrete snapshot logic for a non-empty state.
doSnapshot(long, long, CheckpointStreamFactory, CheckpointOptions) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy
 
doSnapshot(long, long, CheckpointStreamFactory, CheckpointOptions) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy
 

E

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.
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).
enableMemTableFlushPending() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
Returns 1 if a memtable flush is pending; otherwise, returns 0.
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.
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.
END_OF_KEY_GROUP_MARK - Static variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksSnapshotUtil
 
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
 

F

FIRST_BIT_IN_BYTE_MASK - Static variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksSnapshotUtil
 
flush() - Method in class org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper
 
fromConfig(Configuration) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
Creates a RocksDBNativeMetricOptions based on an external configuration.

G

getCheckpointBackend() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
Gets the state backend that this RocksDB state backend uses to persist its bytes to.
getColumnFamilyHandle(String) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
 
getColumnOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
Gets the RocksDB ColumnFamilyOptions to be used for all RocksDB instances.
getConfigKey() - Method in enum org.apache.flink.contrib.streaming.state.RocksDBProperty
 
getDbOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
Gets the RocksDB DBOptions to be used for all RocksDB instances.
getDbStoragePaths() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
Gets the configured local DB storage paths, or null, if none were configured.
getDefaultValue() - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
 
getInstanceBasePath() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
Only visible for testing, DO NOT USE.
getInternalIndex() - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
 
getKeyGroupPrefixBytes() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
 
getKeys(String, N) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
 
getMemoryWatcherOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
 
getOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
Gets the options factory that lazily creates the RocksDB options.
getOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper
 
getPredefinedOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
Gets the currently set predefined options for RocksDB.
getProperties() - Method in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
 
getRocksDBProperty() - Method in enum org.apache.flink.contrib.streaming.state.RocksDBProperty
 
getRocksIterator(RocksDB) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
 
getRocksIterator(RocksDB, ColumnFamilyHandle) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
 
getSerializedValue(byte[], TypeSerializer<K>, TypeSerializer<N>, TypeSerializer<V>) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
 
getWriteOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
 

H

hasMetaDataFollowsFlag(byte[]) - Static method in class org.apache.flink.contrib.streaming.state.snapshot.RocksSnapshotUtil
 
hasNext() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysIterator
 

I

isAmbiguousKeyPossible(TypeSerializer, TypeSerializer) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils
 
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 is any property 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.RocksDBStateBackend
Gets whether incremental checkpoints are enabled for this state backend.
isNewKeyGroup() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
Indicates if current key starts a new key-group, i.e.
isNewKeyValueState() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
Indicates if current key starts a new k/v-state, i.e.
isValid() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
Check if the iterator is still valid.
isValid() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
 
iterator() - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
 

K

key() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
 
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.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.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.
LOCAL_DIRECTORIES - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions
The local directory (on the TaskManager) where RocksDB puts its files.
localRecoveryConfig - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
The configuration for local recovery.

M

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
 
MERGE_OPERATOR_NAME - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
The name of the merge operator in RocksDB.
migrateSerializedValue(DataInputDeserializer, DataOutputSerializer, TypeSerializer<V>, TypeSerializer<V>) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
 
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_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_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_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_TOTAL_SST_FILES_SIZE - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
 

N

next() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysIterator
 
next() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator
Advances the iterator.
next() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksTransformingIteratorWrapper
 
next() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
 
notifyCheckpointComplete(long) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
 
notifyCheckpointComplete(long) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy
 
notifyCheckpointComplete(long) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy
 
numKeyValueStateEntries() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
 

O

OptionsFactory - Interface in org.apache.flink.contrib.streaming.state
A factory for DBOptions and ColumnFamilyOptions to be passed to the RocksDBStateBackend.
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.snapshot - package org.apache.flink.contrib.streaming.state.snapshot
 

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
 
PredefinedOptions - Enum in org.apache.flink.contrib.streaming.state
The PredefinedOptions are configuration settings for the RocksDBStateBackend.
prev() - Method in class org.apache.flink.contrib.streaming.state.iterator.RocksTransformingIteratorWrapper
 
prev() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
 
put(ColumnFamilyHandle, byte[], byte[]) - Method in class org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper
 

R

readKey(TypeSerializer<K>, DataInputDeserializer, boolean) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils
 
readNamespace(TypeSerializer<N>, DataInputDeserializer, boolean) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils
 
remove(byte[]) - Method in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache
Removes the given element, if it is contained.
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
 
remove(byte[]) - Method in class org.apache.flink.contrib.streaming.state.TreeOrderedSetCache
 
requiresLegacySynchronousTimerSnapshots() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
 
resolveCheckpoint(String) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
 
restore(Collection<KeyedStateHandle>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
 
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.
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
 
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(String, ClassLoader, File, DBOptions, ColumnFamilyOptions, TaskKvStateRegistry, TypeSerializer<K>, int, KeyGroupRange, ExecutionConfig, boolean, LocalRecoveryConfig, RocksDBStateBackend.PriorityQueueStateType, TtlTimeProvider, RocksDBNativeMetricOptions, MetricGroup) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
 
RocksDBKeySerializationUtils - Class in org.apache.flink.contrib.streaming.state
Utils for RocksDB state serialization and deserialization.
RocksDBKeySerializationUtils() - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils
 
RocksDBNativeMetricMonitor - Class in org.apache.flink.contrib.streaming.state
A monitor which pulls {RocksDB} native metrics and forwards them to Flink's metric group.
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
 
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
 
RocksDBProperty - Enum in org.apache.flink.contrib.streaming.state
RocksDB properties that can be queried by Flink's metrics reporter.
rocksDBResourceGuard - Variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
Resource guard for the RocksDB instance.
RocksDBSnapshotStrategyBase<K> - 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, Tuple2<ColumnFamilyHandle, RegisteredStateMetaInfoBase>>, KeyGroupRange, int, LocalRecoveryConfig, CloseableRegistry) - Constructor for class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
 
RocksDBStateBackend - Class in org.apache.flink.contrib.streaming.state
A State Backend that stores its state in RocksDB.
RocksDBStateBackend(String) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
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
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
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
Creates a new RocksDBStateBackend that stores its checkpoint data in the file system and location defined by the given URI.
RocksDBStateBackend(StateBackend) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
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
Creates a new RocksDBStateBackend that uses the given state backend to store its checkpoint data streams.
RocksDBStateBackend(AbstractStateBackend) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
RocksDBStateBackend(AbstractStateBackend, boolean) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
RocksDBStateBackend.PriorityQueueStateType - Enum in org.apache.flink.contrib.streaming.state
The options to chose for the type of priority queue state.
RocksDBStateBackendFactory - Class in org.apache.flink.contrib.streaming.state
A factory that creates an RocksDBStateBackend from a configuration.
RocksDBStateBackendFactory() - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory
 
RocksDBWriteBatchWrapper - Class in org.apache.flink.contrib.streaming.state
It's a wrapper class around RocksDB's WriteBatch for writing in bulk.
RocksDBWriteBatchWrapper(RocksDB) - 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) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper
 
RocksFullSnapshotStrategy<K> - Class in org.apache.flink.contrib.streaming.state.snapshot
Snapshot strategy to create full snapshots of RocksDBKeyedStateBackend.
RocksFullSnapshotStrategy(RocksDB, ResourceGuard, TypeSerializer<K>, LinkedHashMap<String, Tuple2<ColumnFamilyHandle, RegisteredStateMetaInfoBase>>, KeyGroupRange, int, LocalRecoveryConfig, CloseableRegistry, StreamCompressionDecorator) - Constructor for class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy
 
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, Tuple2<ColumnFamilyHandle, RegisteredStateMetaInfoBase>>, KeyGroupRange, int, LocalRecoveryConfig, CloseableRegistry, File, UUID, SortedMap<Long, Set<StateHandleID>>, long) - Constructor for class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy
 
RocksIteratorWrapper - Class in org.apache.flink.contrib.streaming.state
This is 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
 
RocksSnapshotUtil - Class in org.apache.flink.contrib.streaming.state.snapshot
Utility methods and constants around RocksDB creating and restoring snapshots for RocksDBKeyedStateBackend.
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(List<Tuple2<RocksIteratorWrapper, Integer>>, int) - Constructor for class org.apache.flink.contrib.streaming.state.iterator.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

seek(byte[]) - 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
 
serializeKeyGroup(int, byte[]) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils
 
setCurrentNamespace(N) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
 
setDbStoragePath(String) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
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.RocksDBStateBackend
Sets the directories in which the local RocksDB database puts its files (like SST and metadata files).
setInternalIndex(int) - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
 
setMetaDataFollowsFlagInKey(byte[]) - Static method in class org.apache.flink.contrib.streaming.state.snapshot.RocksSnapshotUtil
 
setOptions(OptionsFactory) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
Sets Options for the RocksDB instances.
setPredefinedOptions(PredefinedOptions) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
Sets the predefined options for RocksDB.
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
 
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.
snapshot(long, long, CheckpointStreamFactory, CheckpointOptions) - Method in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase
 
SST_FILE_SUFFIX - Static variable in class org.apache.flink.contrib.streaming.state.snapshot.RocksSnapshotUtil
File suffix of sstable files.
status() - Method in class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
 
supportsAsynchronousSnapshots() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend
 

T

TIMER_SERVICE_FACTORY - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBOptions
Choice of timer service implementation.
toString() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
 
TRACK_COMPACTION_PENDING - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions
 
TreeOrderedSetCache - Class in org.apache.flink.contrib.streaming.state
Implementation of a lexicographically ordered set of byte-arrays, based on a TreeSet.

V

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 class org.apache.flink.contrib.streaming.state.RocksIteratorWrapper
 
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
Returns the enum constant of this type with the specified name.
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
Returns an array containing the constants of this enum type, in the order they are declared.

W

writeCurrentKeyWithGroupAndNamespace() - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
 
writeKey(K, TypeSerializer<K>, DataOutputSerializer, boolean) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils
 
writeKeyGroup(int, int, DataOutputView) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils
 
writeKeyWithGroupAndNamespace(int, K, N, DataOutputSerializer) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
 
writeKeyWithGroupAndNamespace(int, K, TypeSerializer<K>, N, TypeSerializer<N>, DataOutputSerializer) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
 
writeNameSpace(N, TypeSerializer<N>, DataOutputSerializer, boolean) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils
 
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 V W 
Skip navigation links

Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.