public class NMTimelinePublisher
extends org.apache.hadoop.service.CompositeService
Constructor and Description |
---|
NMTimelinePublisher(Context context) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.yarn.event.AsyncDispatcher |
createDispatcher() |
void |
createTimelineClient(org.apache.hadoop.yarn.api.records.ApplicationId appId) |
protected void |
handleNMTimelineEvent(NMTimelineEvent event) |
void |
publishApplicationEvent(ApplicationEvent event) |
void |
publishContainerEvent(ContainerEvent event) |
void |
publishLocalizationEvent(LocalizationEvent event) |
void |
reportContainerResourceUsage(Container container,
Long pmemUsage,
Float cpuUsagePercentPerCore) |
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
protected void |
serviceStart() |
protected void |
serviceStop() |
void |
setTimelineServiceAddress(org.apache.hadoop.yarn.api.records.ApplicationId appId,
String collectorAddr) |
void |
stopTimelineClient(org.apache.hadoop.yarn.api.records.ApplicationId appId) |
addIfService, addService, getServices, removeService
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public NMTimelinePublisher(Context context)
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.CompositeService
Exception
protected org.apache.hadoop.yarn.event.AsyncDispatcher createDispatcher()
protected void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.CompositeService
Exception
protected void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.CompositeService
Exception
protected void handleNMTimelineEvent(NMTimelineEvent event)
public void reportContainerResourceUsage(Container container, Long pmemUsage, Float cpuUsagePercentPerCore)
public void publishApplicationEvent(ApplicationEvent event)
public void publishContainerEvent(ContainerEvent event)
public void publishLocalizationEvent(LocalizationEvent event)
public void createTimelineClient(org.apache.hadoop.yarn.api.records.ApplicationId appId)
public void stopTimelineClient(org.apache.hadoop.yarn.api.records.ApplicationId appId)
public void setTimelineServiceAddress(org.apache.hadoop.yarn.api.records.ApplicationId appId, String collectorAddr)
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.