| Interface | Description |
|---|---|
| Monitor |
A Monitor is a class implementing some functionality that should be done every N milliseconds on a YARN RM or NM.
|
| MonitorFactory |
Factory to build
Monitor using provided config. |
| SchedulingProvider |
Provides scheduling functionality to the SamzaMonitorService.
|
| Class | Description |
|---|---|
| JobsClient |
This is a helper class to interact with the samza-rest apis.
|
| LocalStoreMonitor |
This monitor class periodically checks for the presence
of stale store directories and deletes them if the
samza task that created it is not running
for more than X days.
|
| LocalStoreMonitorConfig |
Configurations for the monitor
LocalStoreMonitor. |
| LocalStoreMonitorFactory |
Factory to build
LocalStoreMonitor using provided config. |
| LocalStoreMonitorMetrics |
Contains all the metrics published by
LocalStoreMonitor. |
| MonitorConfig |
Configurations for the
Monitor implementations. |
| MonitorLoader |
Helper class that instantiates the Monitor.
|
| SamzaMonitorService |
The class responsible for handling long-running/scheduled monitors in Samza REST.
|
| ScheduledExecutorSchedulingProvider |