Package | Description |
---|---|
org.apache.flink.contrib.streaming.state |
Class and Description |
---|
AbstractRocksDBState
Base class for
State implementations that store state in a RocksDB database. |
AbstractRocksDBState.AbstractRocksDBSnapshot |
DbAdapter
Adapter interface for executing different checkpointing related operations on
the underlying database.
|
DbBackendConfig
Configuration object for
DbStateBackend , containing information to
shard and connect to the databases that will store the state checkpoints. |
OptionsFactory
A factory for
Options to be passed to the RocksDBStateBackend . |
PredefinedOptions
The
PredefinedOptions are configuration settings for the RocksDBStateBackend . |
RocksDBStateBackend
A
StateBackend that stores its state in RocksDB . |
ShardedConnection
Helper class to maintain a sharded database connection and get
Connection s and PreparedStatement s for keys. |
ShardedConnection.Partitioner |
ShardedConnection.ShardedStatement |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.