Package org.apache.kafka.streams.state
Interface VersionedBytesStore
- All Superinterfaces:
KeyValueStore<org.apache.kafka.common.utils.Bytes,
,byte[]> ReadOnlyKeyValueStore<org.apache.kafka.common.utils.Bytes,
,byte[]> StateStore
,TimestampedBytesStore
public interface VersionedBytesStore
extends KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>, 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[]
delete
(org.apache.kafka.common.utils.Bytes key, long timestamp) The analog ofVersionedKeyValueStore.delete(Object, long)
.byte[]
get
(org.apache.kafka.common.utils.Bytes key, long asOfTimestamp) The analog ofVersionedKeyValueStore.get(Object, long)
.long
put
(org.apache.kafka.common.utils.Bytes key, byte[] value, long timestamp) The analog ofVersionedKeyValueStore.put(Object, Object, long)
.Methods inherited from interface org.apache.kafka.streams.state.KeyValueStore
delete, put, putAll, putIfAbsent
Methods inherited from interface org.apache.kafka.streams.state.ReadOnlyKeyValueStore
all, approximateNumEntries, get, prefixScan, range, reverseAll, reverseRange
Methods inherited from interface org.apache.kafka.streams.processor.StateStore
close, flush, getPosition, init, init, isOpen, name, persistent, query
-
Method Details
-
put
long put(org.apache.kafka.common.utils.Bytes key, byte[] value, long timestamp) The analog ofVersionedKeyValueStore.put(Object, Object, long)
. -
get
byte[] get(org.apache.kafka.common.utils.Bytes key, long asOfTimestamp) The analog ofVersionedKeyValueStore.get(Object, long)
. -
delete
byte[] delete(org.apache.kafka.common.utils.Bytes key, long timestamp) The analog ofVersionedKeyValueStore.delete(Object, long)
.
-