public interface VersionedBytesStore extends KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>, TimestampedBytesStore
KeyValueStore of type <Bytes, byte[]>. See VersionedBytesStoreSupplier for more.| 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). |
delete, put, putAll, putIfAbsentclose, flush, getPosition, init, init, isOpen, name, persistent, queryall, approximateNumEntries, get, prefixScan, range, reverseAll, reverseRangeconvertToTimestampedFormatlong put(org.apache.kafka.common.utils.Bytes key,
byte[] value,
long timestamp)VersionedKeyValueStore.put(Object, Object, long).byte[] get(org.apache.kafka.common.utils.Bytes key,
long asOfTimestamp)VersionedKeyValueStore.get(Object, long).byte[] delete(org.apache.kafka.common.utils.Bytes key,
long timestamp)VersionedKeyValueStore.delete(Object, long).