public class NMLogAggregationStatusTracker
extends org.apache.hadoop.service.CompositeService
NMLogAggregationStatusTracker
is used to cache log aggregation
status for finished applications. It will also delete the old cached
log aggregation status periodically.Constructor and Description |
---|
NMLogAggregationStatusTracker(Context context) |
Modifier and Type | Method and Description |
---|---|
List<org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport> |
pullCachedLogAggregationReports() |
protected void |
serviceStart() |
void |
serviceStop() |
void |
updateLogAggregationStatus(org.apache.hadoop.yarn.api.records.ApplicationId appId,
org.apache.hadoop.yarn.api.records.LogAggregationStatus logAggregationStatus,
long updateTime,
String diagnosis,
boolean finalized) |
addIfService, addService, getServices, removeService, serviceInit
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public NMLogAggregationStatusTracker(Context context)
protected void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.CompositeService
Exception
public void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.CompositeService
Exception
public void updateLogAggregationStatus(org.apache.hadoop.yarn.api.records.ApplicationId appId, org.apache.hadoop.yarn.api.records.LogAggregationStatus logAggregationStatus, long updateTime, String diagnosis, boolean finalized)
public List<org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport> pullCachedLogAggregationReports()
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.