void init(ProcessorContext context)
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
|
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