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.

Method Summary

Methods inherited from interface org.apache.kafka.streams.state.WindowStore

backwardFetch, backwardFetch, backwardFetch, backwardFetch, backwardFetchAll, backwardFetchAll, fetch, fetch, fetch, fetch, fetchAll, fetchAll, put, put

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.ReadOnlyWindowStore

all, backwardAll, fetch