public class AppLogAggregatorImpl extends Object implements AppLogAggregator
Constructor and Description |
---|
AppLogAggregatorImpl(org.apache.hadoop.yarn.event.Dispatcher dispatcher,
DeletionService deletionService,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.yarn.api.records.ApplicationId appId,
org.apache.hadoop.security.UserGroupInformation userUgi,
org.apache.hadoop.yarn.api.records.NodeId nodeId,
LocalDirsHandlerService dirsHandler,
org.apache.hadoop.fs.Path remoteNodeLogFileForApp,
org.apache.hadoop.yarn.logaggregation.ContainerLogsRetentionPolicy retentionPolicy,
Map<org.apache.hadoop.yarn.api.records.ApplicationAccessType,String> appAcls,
org.apache.hadoop.yarn.api.records.LogAggregationContext logAggregationContext,
Context context,
org.apache.hadoop.fs.FileContext lfs) |
Modifier and Type | Method and Description |
---|---|
void |
abortLogAggregation() |
void |
doLogAggregationOutOfBand() |
void |
finishLogAggregation() |
org.apache.hadoop.security.UserGroupInformation |
getUgi() |
void |
run() |
void |
startContainerLogAggregation(org.apache.hadoop.yarn.api.records.ContainerId containerId,
boolean wasContainerSuccessful) |
public AppLogAggregatorImpl(org.apache.hadoop.yarn.event.Dispatcher dispatcher, DeletionService deletionService, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.yarn.api.records.ApplicationId appId, org.apache.hadoop.security.UserGroupInformation userUgi, org.apache.hadoop.yarn.api.records.NodeId nodeId, LocalDirsHandlerService dirsHandler, org.apache.hadoop.fs.Path remoteNodeLogFileForApp, org.apache.hadoop.yarn.logaggregation.ContainerLogsRetentionPolicy retentionPolicy, Map<org.apache.hadoop.yarn.api.records.ApplicationAccessType,String> appAcls, org.apache.hadoop.yarn.api.records.LogAggregationContext logAggregationContext, Context context, org.apache.hadoop.fs.FileContext lfs)
public void startContainerLogAggregation(org.apache.hadoop.yarn.api.records.ContainerId containerId, boolean wasContainerSuccessful)
startContainerLogAggregation
in interface AppLogAggregator
public void finishLogAggregation()
finishLogAggregation
in interface AppLogAggregator
public void abortLogAggregation()
abortLogAggregation
in interface AppLogAggregator
@InterfaceAudience.Private public void doLogAggregationOutOfBand()
public org.apache.hadoop.security.UserGroupInformation getUgi()
Copyright © 2017 Apache Software Foundation. All Rights Reserved.