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>>
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, getPosition, init, init, isOpen, name, persistent, queryMethods inherited from interface org.apache.kafka.streams.state.WindowStore
backwardFetch, backwardFetch, backwardFetch, backwardFetch, backwardFetchAll, backwardFetchAll, fetch, fetch, fetch, fetch, fetchAll, fetchAll, put