void close()KStreamTransformProcessor
KStreamTransformProcessor is a processor that is used for KStream.transform stateful operator.
KStreamTransformProcessor takes a single Transformer when created.
Closing Processor — close Method
|
Note
|
close is part of the Processor Contract to close the processor.
|
close…FIXME
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(K1 key, V1 value)|
Note
|
process is part of the Processor Contract to process a single record.
|
process…FIXME