org.apache.samza.monitor

Class SamzaMonitorService

java.lang.Object

org.apache.samza.monitor.SamzaMonitorService

public class SamzaMonitorService
extends java.lang.Object

The class responsible for handling long-running/scheduled monitors in Samza REST. Takes a SamzaRestConfig object in the constructor and handles instantiation of monitors and scheduling them to run based on the properties in the config.

Constructor Summary

Constructors

Constructor and Description
SamzaMonitorService(SamzaRestConfig config, org.apache.samza.metrics.MetricsRegistry metricsRegistry)

Method Summary

Modifier and Type	Method and Description
void	createSchedulerAndScheduleMonitor(java.lang.String monitorName, MonitorConfig monitorConfig, long schedulingIntervalInMs) Creates a ScheduledThreadPoolExecutor with core pool size 1 and schedules the monitor to run every schedulingIntervalInMs
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SamzaMonitorService

public SamzaMonitorService(SamzaRestConfig config,
                           org.apache.samza.metrics.MetricsRegistry metricsRegistry)

Method Detail

start

public void start()

stop

public void stop()

createSchedulerAndScheduleMonitor

public void createSchedulerAndScheduleMonitor(java.lang.String monitorName,
                                              MonitorConfig monitorConfig,
                                              long schedulingIntervalInMs)
                                       throws java.lang.InstantiationException

Creates a ScheduledThreadPoolExecutor with core pool size 1 and schedules the monitor to run every schedulingIntervalInMs

Throws:

java.lang.InstantiationException