Package org.apache.hadoop.yarn.server.resourcemanager.metrics

Class TimelineServiceV1Publisher

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.service.CompositeService

org.apache.hadoop.yarn.server.resourcemanager.metrics.AbstractSystemMetricsPublisher

org.apache.hadoop.yarn.server.resourcemanager.metrics.TimelineServiceV1Publisher

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service, SystemMetricsPublisher

public class TimelineServiceV1Publisher
extends AbstractSystemMetricsPublisher

This class is responsible for posting application, appattempt & Container lifecycle related events to timeline service v1.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.yarn.server.resourcemanager.metrics.AbstractSystemMetricsPublisher

AbstractSystemMetricsPublisher.MultiThreadedDispatcher, AbstractSystemMetricsPublisher.SystemMetricsEventType, AbstractSystemMetricsPublisher.TimelinePublishEvent

Nested classes/interfaces inherited from class org.apache.hadoop.service.CompositeService

org.apache.hadoop.service.CompositeService.CompositeServiceShutdownHook

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.service.CompositeService

STOP_ONLY_STARTED_SERVICES

Constructor Summary

Constructors

Constructor	Description
TimelineServiceV1Publisher()

Method Summary

Modifier and Type	Method	Description
void	appACLsUpdated(RMApp app, String appViewACLs, long updatedTime)
void	appAttemptFinished(RMAppAttempt appAttempt, RMAppAttemptState appAttemptState, 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	appLaunched(RMApp app, long launchTime)
void	appStateUpdated(RMApp app, org.apache.hadoop.yarn.api.records.YarnApplicationState appState, long updatedTime)
void	appUpdated(RMApp app, long updatedTime)
void	containerCreated(RMContainer container, long createdTime)
void	containerFinished(RMContainer container, long finishedTime)
protected void	serviceInit(org.apache.hadoop.conf.Configuration conf)
protected void	serviceStart()
protected void	serviceStop()

Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.metrics.AbstractSystemMetricsPublisher

getDispatcher

Methods inherited from class org.apache.hadoop.service.CompositeService

addIfService, addService, getServices, removeService

Methods 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

Methods inherited from class java.lang.Object

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

Constructor Details

TimelineServiceV1Publisher

public TimelineServiceV1Publisher()

Method Details

serviceInit

protected void serviceInit(org.apache.hadoop.conf.Configuration conf)
                    throws Exception

Overrides:

serviceInit in class AbstractSystemMetricsPublisher

Throws:

Exception

serviceStart

protected void serviceStart()
                     throws Exception

Overrides:

serviceStart in class org.apache.hadoop.service.CompositeService

Throws:

Exception

serviceStop

protected void serviceStop()
                    throws Exception

Overrides:

serviceStop in class org.apache.hadoop.service.CompositeService

Throws:

Exception

appCreated

public void appCreated(RMApp app,
 long createdTime)

appLaunched

public void appLaunched(RMApp app,
 long launchTime)

Specified by:

appLaunched in interface SystemMetricsPublisher

Overrides:

appLaunched in class AbstractSystemMetricsPublisher

appFinished

public void appFinished(RMApp app,
 RMAppState state,
 long finishedTime)

appUpdated

public void appUpdated(RMApp app,
 long updatedTime)

appStateUpdated

public void appStateUpdated(RMApp app,
 org.apache.hadoop.yarn.api.records.YarnApplicationState appState,
 long updatedTime)

appACLsUpdated

public void appACLsUpdated(RMApp app,
 String appViewACLs,
 long updatedTime)

appAttemptRegistered

public void appAttemptRegistered(RMAppAttempt appAttempt,
 long registeredTime)

appAttemptFinished

public void appAttemptFinished(RMAppAttempt appAttempt,
 RMAppAttemptState appAttemptState,
 RMApp app,
 long finishedTime)

containerCreated

public void containerCreated(RMContainer container,
 long createdTime)

containerFinished

public void containerFinished(RMContainer container,
 long finishedTime)