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) |
protected void |
createAppDir(String user,
org.apache.hadoop.yarn.api.records.ApplicationId appId,
org.apache.hadoop.security.UserGroupInformation userUgi) |
protected org.apache.hadoop.fs.FileSystem |
getFileSystem(org.apache.hadoop.conf.Configuration conf) |
void |
handle(LogHandlerEvent event) |
protected void |
initAppAggregator(org.apache.hadoop.yarn.api.records.ApplicationId appId,
String user,
org.apache.hadoop.security.Credentials credentials,
org.apache.hadoop.yarn.logaggregation.ContainerLogsRetentionPolicy logRetentionPolicy,
Map<org.apache.hadoop.yarn.api.records.ApplicationAccessType,String> appAcls) |
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 org.apache.hadoop.fs.FileSystem getFileSystem(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
protected void createAppDir(String user, org.apache.hadoop.yarn.api.records.ApplicationId appId, org.apache.hadoop.security.UserGroupInformation userUgi)
protected void initAppAggregator(org.apache.hadoop.yarn.api.records.ApplicationId appId, String user, org.apache.hadoop.security.Credentials credentials, org.apache.hadoop.yarn.logaggregation.ContainerLogsRetentionPolicy logRetentionPolicy, Map<org.apache.hadoop.yarn.api.records.ApplicationAccessType,String> appAcls)
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
Copyright © 2015 Apache Software Foundation. All Rights Reserved.