Package org.apache.kafka.streams.state

Interface TimestampedKeyValueStore<K,V>

Type Parameters:

K - The key type

V - The value type

All Superinterfaces:

KeyValueStore<K,ValueAndTimestamp<V>>, ReadOnlyKeyValueStore<K,ValueAndTimestamp<V>>, StateStore

public interface TimestampedKeyValueStore<K,V>
extends KeyValueStore<K,ValueAndTimestamp<V>>

A key-(value/timestamp) store that supports put/get/delete and range queries.

Method Summary

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