KStreamSessionWindowAggregateProcessor

KStreamSessionWindowAggregateProcessor is a concrete stream processor that…​FIXME

KStreamSessionWindowAggregateProcessor is created exclusively when KStreamSessionWindowAggregate is requested to supply a stream processor.

Note
KStreamSessionWindowAggregateProcessor is a private class of KStreamSessionWindowAggregate.
Table 1. KStreamSessionWindowAggregateProcessor’s Internal Properties (e.g. Registries, Counters and Flags)
Name Description

store

SessionStore

Used when…​FIXME

tupleForwarder

TupleForwarder of Windowed keys

Used when…​FIXME

Processing Single Record — process Method

void process(final K key, final V value)
Note
process is part of Processor Contract to…​FIXME.

process…​FIXME

Initializing Stream Processor — init Method

void init(ProcessorContext context)
Note
init is part of Processor Contract to initialize a stream processor.

init requests the input ProcessorContext for the SessionStore (by the storeName of the owning KStreamSessionWindowAggregate) and sets it as the current SessionStore.

init creates a ForwardingCacheFlushListener (with the sendOldValues flag of the owning KStreamSessionWindowAggregate).

In the end, init creates a TupleForwarder (with the SessionStore, the ForwardingCacheFlushListener and the sendOldValues flag of the owning KStreamSessionWindowAggregate).

results matching ""

    No results matching ""