protected static class SystemMetricsPublisher.MultiThreadedDispatcher
extends org.apache.hadoop.service.CompositeService
implements org.apache.hadoop.yarn.event.Dispatcher
Constructor and Description |
---|
SystemMetricsPublisher.MultiThreadedDispatcher(int num) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.yarn.event.AsyncDispatcher |
createDispatcher() |
org.apache.hadoop.yarn.event.EventHandler |
getEventHandler() |
void |
register(Class<? extends Enum> eventType,
org.apache.hadoop.yarn.event.EventHandler handler) |
void |
setDrainEventsOnStop() |
addIfService, addService, getServices, removeService, serviceInit, serviceStart, serviceStop
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public SystemMetricsPublisher.MultiThreadedDispatcher(int num)
public org.apache.hadoop.yarn.event.EventHandler getEventHandler()
getEventHandler
in interface org.apache.hadoop.yarn.event.Dispatcher
public void register(Class<? extends Enum> eventType, org.apache.hadoop.yarn.event.EventHandler handler)
register
in interface org.apache.hadoop.yarn.event.Dispatcher
public void setDrainEventsOnStop()
protected org.apache.hadoop.yarn.event.AsyncDispatcher createDispatcher()
Copyright © 2017 Apache Software Foundation. All Rights Reserved.