Class AMLivelinessMonitor
java.lang.Object
org.apache.hadoop.service.AbstractService
org.apache.hadoop.yarn.util.AbstractLivelinessMonitor<org.apache.hadoop.yarn.api.records.ApplicationAttemptId>
org.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt.AMLivelinessMonitor
- All Implemented Interfaces:
Closeable,AutoCloseable,org.apache.hadoop.service.Service
public class AMLivelinessMonitor
extends org.apache.hadoop.yarn.util.AbstractLivelinessMonitor<org.apache.hadoop.yarn.api.records.ApplicationAttemptId>
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service
org.apache.hadoop.service.Service.STATE -
Field Summary
Fields inherited from class org.apache.hadoop.yarn.util.AbstractLivelinessMonitor
DEFAULT_EXPIRE -
Constructor Summary
ConstructorsConstructorDescriptionAMLivelinessMonitor(org.apache.hadoop.yarn.event.Dispatcher d) AMLivelinessMonitor(org.apache.hadoop.yarn.event.Dispatcher d, org.apache.hadoop.yarn.util.Clock clock) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidexpire(org.apache.hadoop.yarn.api.records.ApplicationAttemptId id) voidserviceInit(org.apache.hadoop.conf.Configuration conf) Methods inherited from class org.apache.hadoop.yarn.util.AbstractLivelinessMonitor
getExpireInterval, receivedPing, register, register, resetTimer, serviceStart, serviceStop, setExpireInterval, setMonitorInterval, setResetTimeOnStart, unregisterMethods inherited from class org.apache.hadoop.service.AbstractService
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
-
Constructor Details
-
AMLivelinessMonitor
public AMLivelinessMonitor(org.apache.hadoop.yarn.event.Dispatcher d) -
AMLivelinessMonitor
public AMLivelinessMonitor(org.apache.hadoop.yarn.event.Dispatcher d, org.apache.hadoop.yarn.util.Clock clock)
-
-
Method Details
-
serviceInit
- Overrides:
serviceInitin classorg.apache.hadoop.service.AbstractService- Throws:
Exception
-
expire
protected void expire(org.apache.hadoop.yarn.api.records.ApplicationAttemptId id) - Specified by:
expirein classorg.apache.hadoop.yarn.util.AbstractLivelinessMonitor<org.apache.hadoop.yarn.api.records.ApplicationAttemptId>
-