Interface TimestampedWindowStore<K,V>

Type Parameters:
K - Type of keys
V - 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.