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 and 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.processor.StateStore

close, flush, getPosition, init, init, isOpen, name, persistent, query

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.state.TimestampedBytesStore

convertToTimestampedFormat

Method Detail

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).