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

A

AbstractRocksDBState<K,N,S extends org.apache.flink.api.common.state.State,SD extends org.apache.flink.api.common.state.StateDescriptor<S,V>,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>, SD, RocksDBKeyedStateBackend<K>) - Constructor for class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

Creates a new RocksDB backed state.

add(T) - Method in class org.apache.flink.contrib.streaming.state.RocksDBAggregatingState

add(T) - Method in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState

Deprecated.

add(V) - Method in class org.apache.flink.contrib.streaming.state.RocksDBListState

add(V) - Method in class org.apache.flink.contrib.streaming.state.RocksDBReducingState

B

backend - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

Backend that holds the actual RocksDB instance where we store state

C

CHECKPOINT_DIRECTORY_URI_CONF_KEY - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory

The key under which the config stores the directory where checkpoints should be stored

clear() - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

clear() - Method in class org.apache.flink.contrib.streaming.state.RocksDBMapState

close() - Method in class org.apache.flink.migration.contrib.streaming.state.RocksDBStateBackend.FinalFullyAsyncSnapshot

Deprecated.

columnFamily - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

The column family of this particular instance of state

contains(UK) - Method in class org.apache.flink.contrib.streaming.state.RocksDBMapState

createAggregatingState(TypeSerializer<N>, AggregatingStateDescriptor<T, ACC, R>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

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.

createFoldingState(TypeSerializer<N>, FoldingStateDescriptor<T, ACC>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

createFromConfig(Configuration) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory

createKeyedStateBackend(Environment, JobID, String, TypeSerializer<K>, int, KeyGroupRange, TaskKvStateRegistry) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend

createListState(TypeSerializer<N>, ListStateDescriptor<T>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

createMapState(TypeSerializer<N>, MapStateDescriptor<UK, UV>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

createOperatorStateBackend(Environment, String) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend

createReducingState(TypeSerializer<N>, ReducingStateDescriptor<T>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

createSavepointStreamFactory(JobID, String, String) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend

createStreamFactory(JobID, String) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend

createValueState(TypeSerializer<N>, ValueStateDescriptor<T>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

D

db - Variable in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

Our RocksDB data base, this is used by the actual subclasses of AbstractRocksDBState to store state.

discardState() - Method in class org.apache.flink.migration.contrib.streaming.state.RocksDBStateBackend.FinalFullyAsyncSnapshot

Deprecated.

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.

E

entries() - Method in class org.apache.flink.contrib.streaming.state.RocksDBMapState

F

FinalSemiAsyncSnapshot() - Constructor for class org.apache.flink.migration.contrib.streaming.state.RocksDBStateBackend.FinalSemiAsyncSnapshot

Deprecated.

G

get() - Method in class org.apache.flink.contrib.streaming.state.RocksDBAggregatingState

get() - Method in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState

Deprecated.

get() - Method in class org.apache.flink.contrib.streaming.state.RocksDBListState

get(UK) - Method in class org.apache.flink.contrib.streaming.state.RocksDBMapState

get() - Method in class org.apache.flink.contrib.streaming.state.RocksDBReducingState

getColumnFamily(StateDescriptor<?, S>, TypeSerializer<N>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

Creates a column family handle for use with a k/v state.

getColumnOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend

Gets the RocksDB ColumnFamilyOptions to be used for all RocksDB instances.

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

getInstanceBasePath() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

Only visible for testing, DO NOT USE.

getKeyGroupPrefixBytes() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

getOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend

Gets the options factory that lazily creates the RocksDB options.

getPredefinedOptions() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend

Gets the currently set predefined options for RocksDB.

getSerializedValue(byte[]) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

getSerializedValue(byte[]) - Method in class org.apache.flink.contrib.streaming.state.RocksDBMapState

getStateSize() - Method in class org.apache.flink.migration.contrib.streaming.state.RocksDBStateBackend.FinalFullyAsyncSnapshot

Deprecated.

I

iterator() - Method in class org.apache.flink.contrib.streaming.state.RocksDBMapState

K

keys() - Method in class org.apache.flink.contrib.streaming.state.RocksDBMapState

keySerializationDataOutputView - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

keySerializationStream - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

L

LOG - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory

M

mergeNamespaces(N, Collection<N>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBAggregatingState

mergeNamespaces(N, Collection<N>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBListState

mergeNamespaces(N, Collection<N>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBReducingState

N

notifyCheckpointComplete(long) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

O

OptionsFactory - Interface in org.apache.flink.contrib.streaming.state

A factory for DBOptions to be passed to the RocksDBStateBackend.

org.apache.flink.contrib.streaming.state - package org.apache.flink.contrib.streaming.state

org.apache.flink.migration.contrib.streaming.state - package org.apache.flink.migration.contrib.streaming.state

P

PredefinedOptions - Enum in org.apache.flink.contrib.streaming.state

The PredefinedOptions are configuration settings for the RocksDBStateBackend.

put(UK, UV) - Method in class org.apache.flink.contrib.streaming.state.RocksDBMapState

putAll(Map<UK, UV>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBMapState

R

readKeyWithGroupAndNamespace(ByteArrayInputStreamWithPos, DataInputView) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

remove(UK) - Method in class org.apache.flink.contrib.streaming.state.RocksDBMapState

restore(Collection<KeyedStateHandle>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

ROCKSDB_CHECKPOINT_DIRECTORY_URI_CONF_KEY - Static variable in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory

The key under which the config stores the directory where RocksDB should be stored

RocksDBAggregatingState<K,N,T,ACC,R> - Class in org.apache.flink.contrib.streaming.state

An AggregatingState implementation that stores state in RocksDB.

RocksDBAggregatingState(ColumnFamilyHandle, TypeSerializer<N>, AggregatingStateDescriptor<T, ACC, R>, RocksDBKeyedStateBackend<K>) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBAggregatingState

Creates a new RocksDBFoldingState.

RocksDBFoldingState<K,N,T,ACC> - Class in org.apache.flink.contrib.streaming.state

Deprecated.

will be removed in a future version

RocksDBFoldingState(ColumnFamilyHandle, TypeSerializer<N>, FoldingStateDescriptor<T, ACC>, RocksDBKeyedStateBackend<K>) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBFoldingState

Deprecated.

Creates a new RocksDBFoldingState.

RocksDBKeyedStateBackend<K> - Class in org.apache.flink.contrib.streaming.state

A AbstractKeyedStateBackend that stores its state in RocksDB and will serialize state to streams provided by a CheckpointStreamFactory upon checkpointing.

RocksDBKeyedStateBackend(String, ClassLoader, File, DBOptions, ColumnFamilyOptions, TaskKvStateRegistry, TypeSerializer<K>, int, KeyGroupRange, ExecutionConfig, boolean) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

RocksDBListState<K,N,V> - Class in org.apache.flink.contrib.streaming.state

ListState implementation that stores state in RocksDB.

RocksDBListState(ColumnFamilyHandle, TypeSerializer<N>, ListStateDescriptor<V>, RocksDBKeyedStateBackend<K>) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBListState

Creates a new RocksDBListState.

RocksDBMapState<K,N,UK,UV> - Class in org.apache.flink.contrib.streaming.state

MapState implementation that stores state in RocksDB.

RocksDBMapState(ColumnFamilyHandle, TypeSerializer<N>, MapStateDescriptor<UK, UV>, RocksDBKeyedStateBackend<K>) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBMapState

Creates a new RocksDBMapState.

RocksDBReducingState<K,N,V> - Class in org.apache.flink.contrib.streaming.state

ReducingState implementation that stores state in RocksDB.

RocksDBReducingState(ColumnFamilyHandle, TypeSerializer<N>, ReducingStateDescriptor<V>, RocksDBKeyedStateBackend<K>) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBReducingState

Creates a new RocksDBReducingState.

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(AbstractStateBackend) - 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, boolean) - 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 - Class in org.apache.flink.migration.contrib.streaming.state

Deprecated.

Internal class used for backwards compatibility.

RocksDBStateBackend() - Constructor for class org.apache.flink.migration.contrib.streaming.state.RocksDBStateBackend

Deprecated.

RocksDBStateBackend.FinalFullyAsyncSnapshot - Class in org.apache.flink.migration.contrib.streaming.state

Deprecated.

Dummy KvStateSnapshot that holds the state of our one RocksDB data base.

RocksDBStateBackend.FinalSemiAsyncSnapshot - Class in org.apache.flink.migration.contrib.streaming.state

Deprecated.

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

RocksDBValueState<K,N,V> - Class in org.apache.flink.contrib.streaming.state

ValueState implementation that stores state in RocksDB.

RocksDBValueState(ColumnFamilyHandle, TypeSerializer<N>, ValueStateDescriptor<V>, RocksDBKeyedStateBackend<K>) - Constructor for class org.apache.flink.contrib.streaming.state.RocksDBValueState

Creates a new RocksDBValueState.

S

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 paths across which the local RocksDB database files are distributed on the local file system.

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.

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.

stateDesc - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

State descriptor from which to create this state instance

stateHandle - Variable in class org.apache.flink.migration.contrib.streaming.state.RocksDBStateBackend.FinalFullyAsyncSnapshot

Deprecated.

supportsAsynchronousSnapshots() - Method in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend

T

toString() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend

U

update(V) - Method in class org.apache.flink.contrib.streaming.state.RocksDBValueState

V

value() - Method in class org.apache.flink.contrib.streaming.state.RocksDBValueState

valueOf(String) - Static method in enum org.apache.flink.contrib.streaming.state.PredefinedOptions

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() - Method in class org.apache.flink.contrib.streaming.state.RocksDBMapState

W

writeCurrentKeyWithGroupAndNamespace() - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

writeKeyWithGroupAndNamespace(int, K, N, ByteArrayOutputStreamWithPos, DataOutputView) - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

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