public static class KStreamTransform.KStreamTransformProcessor<K1,V1,K2,V2> extends AbstractProcessor<K1,V1>
Constructor and Description |
---|
KStreamTransformProcessor(Transformer<? super K1,? super V1,? extends KeyValue<? extends K2,? extends V2>> transformer) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close this processor and clean up any resources.
|
void |
init(ProcessorContext context)
Initialize this processor with the given context.
|
void |
process(K1 key,
V1 value)
Process the record with the given key and value.
|
context
public void init(ProcessorContext context)
Processor
Processor.close()
will be called on it; the
framework may later re-use the processor by calling #init()
again.
The provided context
can be used to access topology and record meta data, to
schedule
a method to be
called periodically
and to access attached StateStore
s.
public void process(K1 key, V1 value)
Processor
key
- the key for the recordvalue
- the value for the recordpublic void close()
AbstractProcessor
This method does nothing by default; if desired, subclasses should override it with custom functionality.