kafka-streams-WindowStore.adoc

WindowStore

WindowStore is the extension of the StateStore contract for state stores that are ReadOnlyWindowStores and can put a record with an optional timestamp.

Table 1. WindowStore Contract

Method	Description
put	void put(K key, V value) // (1) void put(K key, V value, long timestamp) Uses the current wall-clock time as the timestamp Used when KStreamJoinWindowProcessor and KStreamWindowAggregateProcessor are requested to process a record

Table 2. WindowStores

WindowStore	Description
CachingWindowStore
ChangeLoggingWindowBytesStore
MeteredWindowStore
RocksDBWindowStore