public class LogAggregationService extends org.apache.hadoop.service.AbstractService implements LogHandler
Constructor and Description |
---|
LogAggregationService(org.apache.hadoop.yarn.event.Dispatcher dispatcher,
Context context,
DeletionService deletionService,
LocalDirsHandlerService dirsHandler) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeFileSystems(org.apache.hadoop.security.UserGroupInformation userUgi) |
ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,AppLogAggregator> |
getAppLogAggregators() |
Set<org.apache.hadoop.yarn.api.records.ApplicationId> |
getInvalidTokenApps() |
org.apache.hadoop.yarn.logaggregation.filecontroller.LogAggregationFileController |
getLogAggregationFileController(org.apache.hadoop.conf.Configuration conf) |
org.apache.hadoop.yarn.api.records.NodeId |
getNodeId() |
long |
getRollingMonitorInterval() |
void |
handle(LogHandlerEvent event) |
protected void |
initAppAggregator(org.apache.hadoop.yarn.api.records.ApplicationId appId,
String user,
org.apache.hadoop.security.Credentials credentials,
Map<org.apache.hadoop.yarn.api.records.ApplicationAccessType,String> appAcls,
org.apache.hadoop.yarn.api.records.LogAggregationContext logAggregationContext,
long recoveredLogInitedTime) |
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
protected void |
serviceStart() |
protected void |
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 LogAggregationService(org.apache.hadoop.yarn.event.Dispatcher dispatcher, Context context, DeletionService deletionService, LocalDirsHandlerService dirsHandler)
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.AbstractService
Exception
protected void initAppAggregator(org.apache.hadoop.yarn.api.records.ApplicationId appId, String user, org.apache.hadoop.security.Credentials credentials, Map<org.apache.hadoop.yarn.api.records.ApplicationAccessType,String> appAcls, org.apache.hadoop.yarn.api.records.LogAggregationContext logAggregationContext, long recoveredLogInitedTime)
protected void closeFileSystems(org.apache.hadoop.security.UserGroupInformation userUgi)
public void handle(LogHandlerEvent event)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<LogHandlerEvent>
handle
in interface LogHandler
public Set<org.apache.hadoop.yarn.api.records.ApplicationId> getInvalidTokenApps()
getInvalidTokenApps
in interface LogHandler
public ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,AppLogAggregator> getAppLogAggregators()
public org.apache.hadoop.yarn.api.records.NodeId getNodeId()
public long getRollingMonitorInterval()
public org.apache.hadoop.yarn.logaggregation.filecontroller.LogAggregationFileController getLogAggregationFileController(org.apache.hadoop.conf.Configuration conf)
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.