K
- the type of keysV
- the type of valuesProcessor<K,V>
public abstract class AbstractProcessor<K,V> extends java.lang.Object implements Processor<K,V>
Processor
that manages the ProcessorContext
instance and provides default no-op
implementations of punctuate(long)
and close()
.Modifier | Constructor | Description |
---|---|---|
protected |
AbstractProcessor() |
Modifier and Type | Method | Description |
---|---|---|
void |
close() |
Close this processor and clean up any resources.
|
protected ProcessorContext |
context() |
Get the processor's context set during
initialization . |
void |
init(ProcessorContext context) |
Initialize this processor with the given context.
|
void |
punctuate(long timestamp) |
Perform any periodic operations, if this processor
schedule itself with the context
during initialization . |
public void init(ProcessorContext context)
Processor
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 punctuate(long timestamp)
schedule itself
with the context
during initialization
.
This method does nothing by default; if desired, subclasses should override it with custom functionality.
public void close()
This method does nothing by default; if desired, subclasses should override it with custom functionality.
protected final ProcessorContext context()
initialization
.initialization
.