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(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, 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, long rollingMonitorInterval)
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, 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, long rollingMonitorInterval, long recoveredLogInitedTime)
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, 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, long rollingMonitorInterval, long recoveredLogInitedTime, org.apache.hadoop.yarn.logaggregation.filecontroller.LogAggregationFileController logAggregationFileController)

Method Summary

Methods

Modifier and Type	Method and Description
void	abortLogAggregation()
void	disableLogAggregation()
void	doLogAggregationOutOfBand()
void	finishLogAggregation()
org.apache.hadoop.yarn.logaggregation.filecontroller.LogAggregationFileController	getLogAggregationFileController()
org.apache.hadoop.yarn.logaggregation.filecontroller.LogAggregationFileControllerContext	getLogAggregationFileControllerContext()
int	getLogAggregationTimes()
org.apache.hadoop.security.UserGroupInformation	getUgi()
void	run()
void	startContainerLogAggregation(org.apache.hadoop.yarn.server.api.ContainerLogContext logContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

AppLogAggregatorImpl

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,
                    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,
                    long rollingMonitorInterval)

AppLogAggregatorImpl

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,
                    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,
                    long rollingMonitorInterval,
                    long recoveredLogInitedTime)

AppLogAggregatorImpl

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,
                    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,
                    long rollingMonitorInterval,
                    long recoveredLogInitedTime,
                    org.apache.hadoop.yarn.logaggregation.filecontroller.LogAggregationFileController logAggregationFileController)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

startContainerLogAggregation

public void startContainerLogAggregation(org.apache.hadoop.yarn.server.api.ContainerLogContext logContext)

Specified by:

startContainerLogAggregation in interface AppLogAggregator

finishLogAggregation

public void finishLogAggregation()

Specified by:

finishLogAggregation in interface AppLogAggregator

abortLogAggregation

public void abortLogAggregation()

Specified by:

abortLogAggregation in interface AppLogAggregator

disableLogAggregation

public void disableLogAggregation()

Specified by:

disableLogAggregation in interface AppLogAggregator

doLogAggregationOutOfBand

@InterfaceAudience.Private
public void doLogAggregationOutOfBand()

getUgi

public org.apache.hadoop.security.UserGroupInformation getUgi()

getLogAggregationTimes

@InterfaceAudience.Private
public int getLogAggregationTimes()

getLogAggregationFileController

public org.apache.hadoop.yarn.logaggregation.filecontroller.LogAggregationFileController getLogAggregationFileController()

getLogAggregationFileControllerContext

public org.apache.hadoop.yarn.logaggregation.filecontroller.LogAggregationFileControllerContext getLogAggregationFileControllerContext()