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

Class AbstractSystemMetricsPublisher

java.lang.Object
org.apache.hadoop.service.AbstractService
org.apache.hadoop.service.CompositeService
org.apache.hadoop.yarn.server.resourcemanager.metrics.AbstractSystemMetricsPublisher
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.service.Service, SystemMetricsPublisher
Direct Known Subclasses:
TimelineServiceV1Publisher, TimelineServiceV2Publisher
public abstract class AbstractSystemMetricsPublisher extends org.apache.hadoop.service.CompositeService implements SystemMetricsPublisher
Abstract implementation of SystemMetricsPublisher which is then extended by metrics publisher implementations depending on timeline service version.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    AbstractSystemMetricsPublisher.MultiThreadedDispatcher
    Dispatches ATS related events using multiple threads.
    protected static enum 
    AbstractSystemMetricsPublisher.SystemMetricsEventType
    EventType which is used while publishing the events.
    protected static class 
    AbstractSystemMetricsPublisher.TimelinePublishEvent
    TimelinePublishEvent's hash code should be based on application's id this will ensure all the events related to a particular app goes to particular thread of MultiThreaded dispatcher.

    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
    AbstractSystemMetricsPublisher(String name)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    appLaunched(RMApp app, long launchTime)
     
    protected org.apache.hadoop.yarn.event.Dispatcher
    getDispatcher()
     
    protected void
    serviceInit(org.apache.hadoop.conf.Configuration conf)
     

    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

    Methods inherited from interface org.apache.hadoop.yarn.server.resourcemanager.metrics.SystemMetricsPublisher

    appACLsUpdated, appAttemptFinished, appAttemptRegistered, appCreated, appFinished, appStateUpdated, appUpdated, containerCreated, containerFinished

  • Constructor Details

    • AbstractSystemMetricsPublisher

      public AbstractSystemMetricsPublisher(String name)

  • Method Details

    • getDispatcher

      protected org.apache.hadoop.yarn.event.Dispatcher getDispatcher()

    • serviceInit

      protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
      Overrides:
      serviceInit in class org.apache.hadoop.service.CompositeService
      Throws:
      Exception

    • appLaunched

      public void appLaunched(RMApp app, long launchTime)
      Specified by:
      appLaunched in interface SystemMetricsPublisher