Package 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
    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

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

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • 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 Details

    • 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

    • enableLogAggregation

      public void enableLogAggregation()
      Specified by:
      enableLogAggregation in interface AppLogAggregator

    • isAggregationEnabled

      public boolean isAggregationEnabled()
      Specified by:
      isAggregationEnabled in interface AppLogAggregator

    • doLogAggregationOutOfBand

      @Private @VisibleForTesting public void doLogAggregationOutOfBand()

    • getUgi

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

    • updateCredentials

      public org.apache.hadoop.security.UserGroupInformation updateCredentials(org.apache.hadoop.security.Credentials cred)
      Specified by:
      updateCredentials in interface AppLogAggregator

    • getLogAggregationFileController

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

    • getLogAggregationFileControllerContext

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