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

KStreamSessionWindowAggregateProcessor