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

results matching ""