Interface | Description |
---|---|
DbAdapter |
Adapter interface for executing different checkpointing related operations on
the underlying database.
|
OptionsFactory |
A factory for
Options to be passed to the RocksDBStateBackend . |
ShardedConnection.Partitioner |
Class | Description |
---|---|
AbstractRocksDBState<K,N,S extends State,SD extends StateDescriptor<S,?>> |
Base class for
State implementations that store state in a RocksDB database. |
AbstractRocksDBState.AbstractRocksDBSnapshot<K,N,S extends State,SD extends StateDescriptor<S,?>> | |
DbBackendConfig |
Configuration object for
DbStateBackend , containing information to
shard and connect to the databases that will store the state checkpoints. |
DbStateBackend |
AbstractStateBackend for storing checkpoints in JDBC supporting databases. |
DbStateHandle<S> |
State handle implementation for storing checkpoints as byte arrays in
databases using the
MySqlAdapter defined in the DbBackendConfig . |
LazyDbValueState<K,N,V> |
Lazily fetched
KvState using a SQL backend. |
MySqlAdapter |
Adapter for bridging inconsistencies between the different SQL
implementations.
|
RocksDBFoldingState<K,N,T,ACC> |
FoldingState implementation that stores state in RocksDB. |
RocksDBListState<K,N,V> |
ListState implementation that stores state in RocksDB. |
RocksDBReducingState<K,N,V> |
ReducingState implementation that stores state in RocksDB. |
RocksDBStateBackend |
A
StateBackend that stores its state in RocksDB . |
RocksDBValueState<K,N,V> |
ValueState implementation that stores state in RocksDB. |
ShardedConnection |
Helper class to maintain a sharded database connection and get
Connection s and PreparedStatement s for keys. |
ShardedConnection.ModHashPartitioner | |
SQLRetrier |
Simple utility to retry failed SQL commands for a predefined number of times
before declaring failure.
|
Enum | Description |
---|---|
PredefinedOptions |
The
PredefinedOptions are configuration settings for the RocksDBStateBackend . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.