@InterfaceAudience.Private
@InterfaceStability.Unstable
public class SystemMetricsPublisher
extends org.apache.hadoop.service.CompositeService
Modifier and Type | Class and Description |
---|---|
protected static class |
SystemMetricsPublisher.MultiThreadedDispatcher |
Constructor and Description |
---|
SystemMetricsPublisher() |
Modifier and Type | Method and Description |
---|---|
void |
appACLsUpdated(RMApp app,
String appViewACLs,
long updatedTime) |
void |
appAttemptFinished(RMAppAttempt appAttempt,
RMAppAttemptState appAttemtpState,
RMApp app,
long finishedTime) |
void |
appAttemptRegistered(RMAppAttempt appAttempt,
long registeredTime) |
void |
appCreated(RMApp app,
long createdTime) |
void |
appFinished(RMApp app,
RMAppState state,
long finishedTime) |
void |
containerCreated(RMContainer container,
long createdTime) |
void |
containerFinished(RMContainer container,
long finishedTime) |
protected org.apache.hadoop.yarn.event.Dispatcher |
createDispatcher(org.apache.hadoop.conf.Configuration conf) |
protected void |
handleSystemMetricsEvent(SystemMetricsEvent event) |
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
addIfService, addService, getServices, removeService, serviceStart, serviceStop
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.CompositeService
Exception
public void appCreated(RMApp app, long createdTime)
public void appFinished(RMApp app, RMAppState state, long finishedTime)
public void appAttemptRegistered(RMAppAttempt appAttempt, long registeredTime)
public void appAttemptFinished(RMAppAttempt appAttempt, RMAppAttemptState appAttemtpState, RMApp app, long finishedTime)
public void containerCreated(RMContainer container, long createdTime)
public void containerFinished(RMContainer container, long finishedTime)
protected org.apache.hadoop.yarn.event.Dispatcher createDispatcher(org.apache.hadoop.conf.Configuration conf)
protected void handleSystemMetricsEvent(SystemMetricsEvent event)
Copyright © 2019 Apache Software Foundation. All Rights Reserved.