org.apache.samza.monitor

Class LocalStoreMonitor

java.lang.Object

org.apache.samza.monitor.LocalStoreMonitor

All Implemented Interfaces:

Monitor

public class LocalStoreMonitor
extends java.lang.Object
implements Monitor

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.

Constructor Summary

Constructors

Constructor and Description
LocalStoreMonitor(LocalStoreMonitorConfig config, LocalStoreMonitorMetrics localStoreMonitorMetrics, JobsClient jobsClient)

Method Summary

Modifier and Type	Method and Description
void	monitor() This monitor method is invoked periodically to delete the stale state stores of dead jobs/tasks.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalStoreMonitor

public LocalStoreMonitor(LocalStoreMonitorConfig config,
                         LocalStoreMonitorMetrics localStoreMonitorMetrics,
                         JobsClient jobsClient)

Method Detail

monitor

public void monitor()
             throws java.lang.Exception

This monitor method is invoked periodically to delete the stale state stores of dead jobs/tasks.

Specified by:

monitor in interface Monitor

Throws:

java.lang.Exception - if there was any problem in running the monitor.