Package org.apache.kafka.streams.state
Interface VersionedBytesStore
- All Superinterfaces:
KeyValueStore<Bytes,,byte[]> ReadOnlyKeyValueStore<Bytes,,byte[]> StateStore,TimestampedBytesStore
A representation of a versioned key-value store as a
KeyValueStore of type <Bytes, byte[]>.
See VersionedBytesStoreSupplier for more.-
Method Summary
Modifier and TypeMethodDescriptionbyte[]The analog ofVersionedKeyValueStore.delete(Object, long).byte[]The analog ofVersionedKeyValueStore.get(Object, long).longThe analog ofVersionedKeyValueStore.put(Object, Object, long).Methods inherited from interface org.apache.kafka.streams.state.KeyValueStore
delete, put, putAll, putIfAbsentMethods inherited from interface org.apache.kafka.streams.state.ReadOnlyKeyValueStore
all, approximateNumEntries, get, prefixScan, range, reverseAll, reverseRangeMethods inherited from interface org.apache.kafka.streams.processor.StateStore
close, commit, committedOffset, flush, getPosition, init, isOpen, managesOffsets, name, persistent, query
-
Method Details
-
put
The analog ofVersionedKeyValueStore.put(Object, Object, long). -
get
The analog ofVersionedKeyValueStore.get(Object, long). -
delete
The analog ofVersionedKeyValueStore.delete(Object, long).
-