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 | contextDeprecated. |
| 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)
ProcessorProcessor.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 StateStores.
public void close()
This method does nothing by default; if desired, subclasses should override it with custom functionality.
protected final ProcessorContext context()
initialization.initialization.