kafka-streams-KStreamSessionWindowAggregateProcessor.adoc

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