@InterfaceStability.Evolving public interface ProcessorLifecycleListenerFactory extends java.io.Serializable
ProcessorLifecycleListener
.Modifier and Type | Method and Description |
---|---|
ProcessorLifecycleListener |
createInstance(ProcessorContext pContext,
Config config)
Create an instance of
ProcessorLifecycleListener for the StreamProcessor |
ProcessorLifecycleListener createInstance(ProcessorContext pContext, Config config)
ProcessorLifecycleListener
for the StreamProcessorpContext
- the context of the corresponding StreamProcessor. Note that ProcessorContext
is just a
placeholder before we have a proper implementation of general context in SAMZA-1714config
- the configuration of the corresponding StreamProcessorProcessorLifecycleListener
callback object for the StreamProcessor