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