Package org.apache.kafka.streams.state
Interface TimestampedWindowStore<K,V>
- Type Parameters:
K- Type of keysV- Type of values
- All Superinterfaces:
ReadOnlyWindowStore<K,ValueAndTimestamp<V>>,StateStore,WindowStore<K,ValueAndTimestamp<V>>
public interface TimestampedWindowStore<K,V> extends WindowStore<K,ValueAndTimestamp<V>>
Interface for storing the aggregated values of fixed-size time windows.
Note, that the stores's physical key type is Windowed<K>.
In contrast to a WindowStore that stores plain windowedKeys-value pairs,
a TimestampedWindowStore stores windowedKeys-(value/timestamp) pairs.
While the window start- and end-timestamp are fixed per window, the value-side timestamp is used to store the last update timestamp of the corresponding window.
-
Method Summary
Methods inherited from interface org.apache.kafka.streams.state.ReadOnlyWindowStore
all, backwardAll, fetchMethods inherited from interface org.apache.kafka.streams.processor.StateStore
close, flush, init, init, isOpen, name, persistentMethods inherited from interface org.apache.kafka.streams.state.WindowStore
backwardFetch, backwardFetch, backwardFetch, backwardFetch, backwardFetchAll, backwardFetchAll, fetch, fetch, fetch, fetch, fetchAll, fetchAll, put