org.apache.hadoop.yarn.server.nodemanager.containermanager.logaggregation

Class AppLogAggregatorImpl

java.lang.Object

org.apache.hadoop.yarn.server.nodemanager.containermanager.logaggregation.AppLogAggregatorImpl

All Implemented Interfaces:

Runnable, AppLogAggregator

public class AppLogAggregatorImpl
extends Object
implements AppLogAggregator

Constructor Summary

Constructors

Constructor and Description
AppLogAggregatorImpl(Dispatcher dispatcher, DeletionService deletionService, Configuration conf, ApplicationId appId, UserGroupInformation userUgi, LocalDirsHandlerService dirsHandler, Path remoteNodeLogFileForApp, ContainerLogsRetentionPolicy retentionPolicy, Map<ApplicationAccessType,String> appAcls)

Method Summary

Methods

Modifier and Type	Method and Description
void	finishLogAggregation()
void	run()
void	startContainerLogAggregation(ContainerId containerId, boolean wasContainerSuccessful)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AppLogAggregatorImpl

public AppLogAggregatorImpl(Dispatcher dispatcher,
                    DeletionService deletionService,
                    Configuration conf,
                    ApplicationId appId,
                    UserGroupInformation userUgi,
                    LocalDirsHandlerService dirsHandler,
                    Path remoteNodeLogFileForApp,
                    ContainerLogsRetentionPolicy retentionPolicy,
                    Map<ApplicationAccessType,String> appAcls)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

startContainerLogAggregation

public void startContainerLogAggregation(ContainerId containerId,
                                boolean wasContainerSuccessful)

Specified by:

startContainerLogAggregation in interface AppLogAggregator

finishLogAggregation

public void finishLogAggregation()

Specified by:

finishLogAggregation in interface AppLogAggregator