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

results matching ""

    No results matching ""