Package org.apache.kafka.streams.state

Interface TimestampedKeyValueStoreWithHeaders<K,V>

Type Parameters:

K - The key type

V - The value type

All Superinterfaces:

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

public interface TimestampedKeyValueStoreWithHeaders<K,V>
extends KeyValueStore<K,ValueTimestampHeaders<V>>

A key-(value/timestamp/headers) store that supports put/get/delete.

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, commit, committedOffset, flush, getPosition, init, isOpen, managesOffsets, name, persistent, query