@InterfaceStability.Evolving public interface ProcessorLifecycleListener
User can implement this interface to instantiate/release shared objects in the local process.
Modifier and Type | Method and Description |
---|---|
default void |
afterFailure(java.lang.Throwable t)
User defined callback after a StreamProcessor is stopped with failure
|
default void |
afterStart()
User defined callback after a StreamProcessor is started
|
default void |
afterStop()
User defined callback after a StreamProcessor is stopped successfully
|
default void |
beforeStart()
User defined initialization before a StreamProcessor is started
|
default void beforeStart()
default void afterStart()
default void afterStop()
default void afterFailure(java.lang.Throwable t)
t
- the error causing the stop of the StreamProcessor.