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 Type	Method	Description
byte[]	delete(org.apache.kafka.common.utils.Bytes key, long timestamp)	The analog of VersionedKeyValueStore.delete(Object, long).
byte[]	get(org.apache.kafka.common.utils.Bytes key, long asOfTimestamp)	The analog of VersionedKeyValueStore.get(Object, long).
long	put(org.apache.kafka.common.utils.Bytes key, byte[] value, long timestamp)	The analog of VersionedKeyValueStore.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 of VersionedKeyValueStore.put(Object, Object, long).

get

byte[] get(org.apache.kafka.common.utils.Bytes key,
 long asOfTimestamp)

The analog of VersionedKeyValueStore.get(Object, long).

delete

byte[] delete(org.apache.kafka.common.utils.Bytes key,
 long timestamp)

The analog of VersionedKeyValueStore.delete(Object, long).