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 | Method and Description |
|---|---|
void | close()Deprecated. Close this processor and clean up any resources. |
void | init(ProcessorContext context)Deprecated. Initialize this processor with the given 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.