KIn - the type of input keysVIn - the type of input valuesKOut - the type of output keysVOut - the type of output valuespublic abstract class ContextualProcessor<KIn,VIn,KOut,VOut> extends Object implements Processor<KIn,VIn,KOut,VOut>
Processor that manages the ProcessorContext instance and provides default no-op implementation of Processor.close().| Modifier | Constructor and Description |
|---|---|
protected | ContextualProcessor() |
| Modifier and Type | Method and Description |
|---|---|
protected ProcessorContext<KOut,VOut> | context()Get the processor's context set during initialization. |
void | init(ProcessorContext<KOut,VOut> context)Initialize this processor with the given context. |
public void init(ProcessorContext<KOut,VOut> 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.
protected final ProcessorContext<KOut,VOut> context()
initialization.initialization.