Class RocksDBTimestampedStore
- java.lang.Object
-
- org.apache.kafka.streams.state.internals.RocksDBStore
-
- org.apache.kafka.streams.state.internals.RocksDBTimestampedStore
-
- All Implemented Interfaces:
StateStore,BatchWritingStore,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>,ReadOnlyKeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>,TimestampedBytesStore
public class RocksDBTimestampedStore extends RocksDBStore implements TimestampedBytesStore
A persistent key-(value-timestamp) store based on RocksDB.
-
-
Field Summary
-
Fields inherited from class org.apache.kafka.streams.state.internals.RocksDBStore
open
-
-
Method Summary
-
Methods inherited from class org.apache.kafka.streams.state.internals.RocksDBStore
addToBatch, all, approximateNumEntries, close, delete, flush, get, getOptions, init, isOpen, name, persistent, put, putAll, putIfAbsent, range, write
-
-