Package org.apache.kafka.streams.state

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.