Interface | Description |
---|---|
ApplicationRunner |
The primary means of managing execution of the
SamzaApplication at runtime. |
LocationIdProvider |
Generates
LocationId that uniquely identifies the
execution environment of a stream processor. |
LocationIdProviderFactory |
Builds the
LocationIdProvider . |
ProcessorContext |
The context for a StreamProcessor.
|
ProcessorIdGenerator | |
ProcessorLifecycleListener |
This interface defines methods that are invoked in different stages of StreamProcessor's lifecycle in local
process (i.e.
|
ProcessorLifecycleListenerFactory |
This interface class defines the factory method to create an instance of
ProcessorLifecycleListener . |
Class | Description |
---|---|
ApplicationRunners |
Creates
ApplicationRunner instances based on configuration and user-implemented SamzaApplication |
LocationId |
Represents the physical execution environment of the StreamProcessor.
|