org.apache.samza.runtime

Interface ProcessorLifecycleListenerFactory

All Superinterfaces:

java.io.Serializable

@InterfaceStability.Evolving
public interface ProcessorLifecycleListenerFactory
extends java.io.Serializable

This interface class defines the factory method to create an instance of ProcessorLifecycleListener.

Method Summary

Modifier and Type	Method and Description
ProcessorLifecycleListener	createInstance(ProcessorContext pContext, Config config) Create an instance of ProcessorLifecycleListener for the StreamProcessor

Method Detail

createInstance

ProcessorLifecycleListener createInstance(ProcessorContext pContext,
                                          Config config)

Create an instance of ProcessorLifecycleListener for the StreamProcessor

Parameters:

pContext - the context of the corresponding StreamProcessor. Note that ProcessorContext is just a placeholder before we have a proper implementation of general context in SAMZA-1714

config - the configuration of the corresponding StreamProcessor

Returns:

the ProcessorLifecycleListener callback object for the StreamProcessor