Package org.apache.kafka.streams.state

Interface TimestampedWindowStoreWithHeaders<K,V>

Type Parameters:
K - Type of keys
V - Type of values
All Superinterfaces:
ReadOnlyWindowStore<K,ValueTimestampHeaders<V>>, StateStore, WindowStore<K,ValueTimestampHeaders<V>>
public interface TimestampedWindowStoreWithHeaders<K,V> extends WindowStore<K,ValueTimestampHeaders<V>>
Interface for storing the aggregated values of fixed-size time windows with headers support.

In contrast to a TimestampedWindowStore that stores windowedKey-(value/timestamp) pairs, a TimestampedWindowStoreWithHeaders stores windowedKey-(value/timestamp/headers) tuples.

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, and headers preserve the record metadata (e.g., schema registry information).