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,
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) |
Modifier and Type | Method and Description |
---|---|
void |
finishLogAggregation() |
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, 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)
public void startContainerLogAggregation(org.apache.hadoop.yarn.api.records.ContainerId containerId, boolean wasContainerSuccessful)
startContainerLogAggregation
in interface AppLogAggregator
public void finishLogAggregation()
finishLogAggregation
in interface AppLogAggregator
Copyright © 2015 Apache Software Foundation. All Rights Reserved.