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