kafka-streams-internals-KStreamJoinWindowProcessor.adoc

KStreamJoinWindowProcessor

KStreamJoinWindowProcessor is a processor that is used for

??? KStream.transform stateful operator.

KStreamJoinWindowProcessor is created when…​FIXME

KStreamJoinWindowProcessor takes no arguments when created.

Initializing Processor — init Method

void init(ProcessorContext context)

Note	init is part of the Processor Contract to initialize the processor.

init…​FIXME

Processing Record — process Method

void process(K key, V value)

Note	process is part of the Processor Contract to process a single record.

process…​FIXME