Package org.apache.hadoop.yarn.server.timelineservice.collector

Class NodeTimelineCollectorManager

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.service.CompositeService

org.apache.hadoop.yarn.server.timelineservice.collector.TimelineCollectorManager

org.apache.hadoop.yarn.server.timelineservice.collector.NodeTimelineCollectorManager

All Implemented Interfaces:

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

@Private
@Unstable
public class NodeTimelineCollectorManager
extends TimelineCollectorManager

Class on the NodeManager side that manages adding and removing collectors and their lifecycle. Also instantiates the per-node collector webapp.

Nested Class Summary

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

Modifier	Constructor	Description
protected	NodeTimelineCollectorManager()
protected	NodeTimelineCollectorManager(boolean asAuxService)

Method Summary

Modifier and Type	Method	Description
void	cancelTokenForAppCollector(AppLevelTimelineCollector appCollector)
protected static org.glassfish.jersey.server.ResourceConfig	configure()
protected TimelineV2DelegationTokenSecretManagerService	createTokenManagerService()
protected void	doPostPut(org.apache.hadoop.yarn.api.records.ApplicationId appId, TimelineCollector collector)	A template method that will be called by TimelineCollectorManager.postPut(ApplicationId, TimelineCollector).
org.apache.hadoop.security.token.Token<org.apache.hadoop.yarn.security.client.TimelineDelegationTokenIdentifier>	generateTokenForAppCollector(String user)
protected org.apache.hadoop.yarn.server.api.CollectorNodemanagerProtocol	getNMCollectorService()
String	getRestServerBindAddress()
TimelineV2DelegationTokenSecretManagerService	getTokenManagerService()
protected void	postRemove(org.apache.hadoop.yarn.api.records.ApplicationId appId, TimelineCollector collector)
long	renewTokenForAppCollector(AppLevelTimelineCollector appCollector)
protected void	serviceInit(org.apache.hadoop.conf.Configuration conf)
protected void	serviceStart()
protected void	serviceStop()

Methods inherited from class org.apache.hadoop.yarn.server.timelineservice.collector.TimelineCollectorManager

containsTimelineCollector, get, getWriter, postPut, putIfAbsent, remove

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

NodeTimelineCollectorManager

@VisibleForTesting
protected NodeTimelineCollectorManager()

NodeTimelineCollectorManager

protected NodeTimelineCollectorManager(boolean asAuxService)

Method Details

serviceInit

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

Overrides:

serviceInit in class TimelineCollectorManager

Throws:

Exception

serviceStart

protected void serviceStart()
                     throws Exception

Overrides:

serviceStart in class TimelineCollectorManager

Throws:

Exception

createTokenManagerService

protected TimelineV2DelegationTokenSecretManagerService createTokenManagerService()

getTokenManagerService

@VisibleForTesting
public TimelineV2DelegationTokenSecretManagerService getTokenManagerService()

serviceStop

protected void serviceStop()
                    throws Exception

Overrides:

serviceStop in class TimelineCollectorManager

Throws:

Exception

generateTokenForAppCollector

@VisibleForTesting
public org.apache.hadoop.security.token.Token<org.apache.hadoop.yarn.security.client.TimelineDelegationTokenIdentifier> generateTokenForAppCollector(String user)

renewTokenForAppCollector

@VisibleForTesting
public long renewTokenForAppCollector(AppLevelTimelineCollector appCollector)
                               throws IOException

Throws:

IOException

cancelTokenForAppCollector

@VisibleForTesting
public void cancelTokenForAppCollector(AppLevelTimelineCollector appCollector)
                                throws IOException

Throws:

IOException

doPostPut

protected void doPostPut(org.apache.hadoop.yarn.api.records.ApplicationId appId,
 TimelineCollector collector)

Description copied from class: TimelineCollectorManager

A template method that will be called by TimelineCollectorManager.postPut(ApplicationId, TimelineCollector).

Overrides:

doPostPut in class TimelineCollectorManager

Parameters:

appId - Application id of the collector.

collector - The actual timeline collector that has been added.

postRemove

protected void postRemove(org.apache.hadoop.yarn.api.records.ApplicationId appId,
 TimelineCollector collector)

Overrides:

postRemove in class TimelineCollectorManager

configure

protected static org.glassfish.jersey.server.ResourceConfig configure()

getNMCollectorService

@VisibleForTesting
protected org.apache.hadoop.yarn.server.api.CollectorNodemanagerProtocol getNMCollectorService()

getRestServerBindAddress

@VisibleForTesting
public String getRestServerBindAddress()