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

Class AppLevelTimelineCollectorWithAgg

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.service.CompositeService

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

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

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

All Implemented Interfaces:

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

@Private
@Unstable
public class AppLevelTimelineCollectorWithAgg
extends AppLevelTimelineCollector

Service that handles aggregations for applications and makes use of AppLevelTimelineCollector class for writes to Timeline Service. App-related lifecycle management is handled by this service.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.yarn.server.timelineservice.collector.TimelineCollector

TimelineCollector.AggregationStatusTable

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.yarn.server.timelineservice.collector.TimelineCollector

SEPARATOR

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

STOP_ONLY_STARTED_SERVICES

Constructor Summary

Constructors

Constructor	Description
AppLevelTimelineCollectorWithAgg(org.apache.hadoop.yarn.api.records.ApplicationId appId, String user)

Method Summary

Modifier and Type	Method	Description
protected Set<String>	getEntityTypesSkipAggregation()	Method to decide the set of timeline entity types the collector should skip on aggregations.
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.AppLevelTimelineCollector

getAppUser, getCurrentUser, getDelegationTokenForApp, getTimelineEntityContext

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

aggregateEntities, getAggregationGroups, isReadyToAggregate, putDomain, putEntities, putEntitiesAsync, setReadyToAggregate, setWriter

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

AppLevelTimelineCollectorWithAgg

public AppLevelTimelineCollectorWithAgg(org.apache.hadoop.yarn.api.records.ApplicationId appId,
 String user)

Method Details

serviceInit

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

Overrides:

serviceInit in class AppLevelTimelineCollector

Throws:

Exception

serviceStart

protected void serviceStart()
                     throws Exception

Overrides:

serviceStart in class AppLevelTimelineCollector

Throws:

Exception

serviceStop

protected void serviceStop()
                    throws Exception

Overrides:

serviceStop in class AppLevelTimelineCollector

Throws:

Exception

getEntityTypesSkipAggregation

protected Set<String> getEntityTypesSkipAggregation()

Description copied from class: TimelineCollector

Method to decide the set of timeline entity types the collector should skip on aggregations. Subclasses may want to override this method to customize their own behaviors.

Overrides:

getEntityTypesSkipAggregation in class TimelineCollector

Returns:

A set of strings consists of all types the collector should skip.