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)
  1. 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 ""

    No results matching ""