| Package | Description |
|---|---|
| org.apache.flink.contrib.streaming.state | |
| org.apache.flink.contrib.streaming.state.iterator |
| Class and Description |
|---|
| OptionsFactory |
| PredefinedOptions
The
PredefinedOptions are configuration settings for the RocksDBStateBackend. |
| RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache
Cache that is organized as an ordered set for byte-arrays.
|
| RocksDBKeyedStateBackend
An
AbstractKeyedStateBackend that stores its state in RocksDB and serializes state to
streams provided by a CheckpointStreamFactory upon
checkpointing. |
| RocksDBNativeMetricOptions
Enable which RocksDB metrics to forward to Flink's metrics reporter.
|
RocksDBProperty
RocksDB properties that can be queried by Flink's metrics reporter. |
| RocksDBStateBackend
A State Backend that stores its state in
RocksDB. |
| RocksDBStateBackend.PriorityQueueStateType
The options to chose for the type of priority queue state.
|
| 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. |
| Class and Description |
|---|
| 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.