Windowed

Windowed is the result key type of a windowed stream aggregation.

Windowed is created when:

KStreamSessionWindowAggregateProcessor and KStreamWindowAggregateProcessor processors are requested to process a record
CachingSessionStore state store is requested to putAndMaybeForward
MergedSortedCacheSessionStoreIterator is requested to deserializeCacheKey
MeteredSessionStore is requested to remove a session and store an aggregated value for a session
MeteredWindowedKeyValueIterator is requested to windowedKey
SessionKeySchema is requested to…FIXME
WindowKeySchema is requested to…FIXME
WindowStoreIteratorWrapper is requested to…FIXME

Windowed takes the following when created:

results matching ""