Package | Description |
---|---|
org.apache.flink.contrib.streaming.state |
Class and Description |
---|
AbstractRocksDBState
Base class for
State implementations that store state in a RocksDB database. |
OptionsFactory |
PredefinedOptions
The
PredefinedOptions are configuration settings for the RocksDBStateBackend . |
RocksDBKeyedStateBackend
An
AbstractKeyedStateBackend that stores its state in RocksDB and serializes state to
streams provided by a CheckpointStreamFactory upon
checkpointing. |
RocksDBStateBackend
A State Backend that stores its state in
RocksDB . |
RocksIteratorWrapper
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. |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.