@InterfaceAudience.Private
@InterfaceStability.Unstable
public class RMApplicationHistoryWriter
extends org.apache.hadoop.service.CompositeService
ResourceManager
uses this class to write the information of
RMApp
, RMAppAttempt
and RMContainer
. These APIs are
non-blocking, and just schedule a writing history event. An self-contained
dispatcher vector will handle the event in separate threads, and extract the
required fields that are going to be persisted. Then, the extracted
information will be persisted via the implementation of
ApplicationHistoryStore
.
Modifier and Type | Class and Description |
---|---|
protected static class |
RMApplicationHistoryWriter.MultiThreadedDispatcher |
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
Constructor and Description |
---|
RMApplicationHistoryWriter() |
Modifier and Type | Method and Description |
---|---|
void |
applicationAttemptFinished(RMAppAttempt appAttempt,
RMAppAttemptState finalState) |
void |
applicationAttemptStarted(RMAppAttempt appAttempt) |
void |
applicationFinished(RMApp app,
RMAppState finalState) |
void |
applicationStarted(RMApp app) |
void |
containerFinished(RMContainer container) |
void |
containerStarted(RMContainer container) |
protected org.apache.hadoop.yarn.server.applicationhistoryservice.ApplicationHistoryStore |
createApplicationHistoryStore(org.apache.hadoop.conf.Configuration conf) |
protected org.apache.hadoop.yarn.event.Dispatcher |
createDispatcher(org.apache.hadoop.conf.Configuration conf) |
protected void |
handleWritingApplicationHistoryEvent(WritingApplicationHistoryEvent event) |
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
addIfService, addService, getServices, removeService, 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
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.CompositeService
Exception
protected org.apache.hadoop.yarn.event.Dispatcher createDispatcher(org.apache.hadoop.conf.Configuration conf)
protected org.apache.hadoop.yarn.server.applicationhistoryservice.ApplicationHistoryStore createApplicationHistoryStore(org.apache.hadoop.conf.Configuration conf)
protected void handleWritingApplicationHistoryEvent(WritingApplicationHistoryEvent event)
public void applicationStarted(RMApp app)
public void applicationFinished(RMApp app, RMAppState finalState)
public void applicationAttemptStarted(RMAppAttempt appAttempt)
public void applicationAttemptFinished(RMAppAttempt appAttempt, RMAppAttemptState finalState)
public void containerStarted(RMContainer container)
public void containerFinished(RMContainer container)
Copyright © 2017 Apache Software Foundation. All Rights Reserved.