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 KeyValueStore

delete, put, putAll, putIfAbsent

Methods inherited from interface ReadOnlyKeyValueStore

all, approximateNumEntries, get, prefixScan, range, reverseAll, reverseRange

Methods inherited from interface StateStore

close, flush, getPosition, 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).