KIn - the type of input keysVIn - the type of input valuesVOut - the type of output valuespublic abstract class ContextualFixedKeyProcessor<KIn,VIn,VOut> extends Object implements FixedKeyProcessor<KIn,VIn,VOut>
FixedKeyProcessor that manages the FixedKeyProcessorContext instance and provides default no-op implementation of FixedKeyProcessor.close().| Modifier | Constructor and Description |
|---|---|
protected | ContextualFixedKeyProcessor() |
| Modifier and Type | Method and Description |
|---|---|
protected FixedKeyProcessorContext<KIn,VOut> | context()Get the processor's context set during initialization. |
void | init(FixedKeyProcessorContext<KIn,VOut> context)Initialize this processor with the given context. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitclose, processpublic void init(FixedKeyProcessorContext<KIn,VOut> context)
FixedKeyProcessorFixedKeyProcessor.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 metadata, to schedule a method to be called periodically and to access attached StateStores.
init in interface FixedKeyProcessor<KIn,VIn,VOut>context - the context; may not be nullprotected final FixedKeyProcessorContext<KIn,VOut> context()
initialization.initialization.