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

Class TimelineServiceV2Publisher

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.TimelineServiceV2Publisher

All Implemented Interfaces:

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

@Private
@Unstable
public class TimelineServiceV2Publisher
extends AbstractSystemMetricsPublisher

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

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
TimelineServiceV2Publisher(RMTimelineCollectorManager timelineCollectorManager)

Method Summary

Modifier and Type	Method	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	appLaunched(RMApp app, long launchTime)
void	appStateUpdated(RMApp app, org.apache.hadoop.yarn.api.records.YarnApplicationState appState, long updatedTime)
void	appUpdated(RMApp app, long currentTimeMillis)
void	containerCreated(RMContainer container, long createdTime)
void	containerFinished(RMContainer container, long finishedTime)
protected void	serviceInit(org.apache.hadoop.conf.Configuration conf)

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, serviceStart, serviceStop

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

TimelineServiceV2Publisher

public TimelineServiceV2Publisher(RMTimelineCollectorManager timelineCollectorManager)

Method Details

serviceInit

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

Overrides:

serviceInit in class AbstractSystemMetricsPublisher

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)

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)

appUpdated

public void appUpdated(RMApp app,
 long currentTimeMillis)

appAttemptRegistered

public void appAttemptRegistered(RMAppAttempt appAttempt,
 long registeredTime)

appAttemptFinished

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

containerCreated

public void containerCreated(RMContainer container,
 long createdTime)

containerFinished

public void containerFinished(RMContainer container,
 long finishedTime)