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