org.apache.hadoop.mapreduce.server.tasktracker.userlogs
Class UserLogManager

java.lang.Object
  extended by org.apache.hadoop.mapreduce.server.tasktracker.userlogs.UserLogManager

public class UserLogManager
extends Object

This manages user logs on the TaskTracker.


Constructor Summary
UserLogManager(Configuration conf)
          Create the user log manager to manage user logs on TaskTracker.
UserLogManager(Configuration conf, TaskController taskController)
          Create the user log manager to manage user logs on TaskTracker.
 
Method Summary
 void addLogEvent(UserLogEvent event)
          Add the UserLogEvent for processing.
 void clearOldUserLogs(Configuration conf)
          Called during TaskTracker restart/re-init.
 TaskController getTaskController()
          Get the taskController for deleting logs.
 UserLogCleaner getUserLogCleaner()
          Get UserLogCleaner.
protected  void monitor()
           
protected  void processEvent(UserLogEvent event)
           
 void start()
          Starts managing the logs
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

UserLogManager

public UserLogManager(Configuration conf,
                      TaskController taskController)
               throws IOException
Create the user log manager to manage user logs on TaskTracker. It should be explicitly started using start() to start functioning

Parameters:
conf - The Configuration
taskController - The task controller to delete the log files
Throws:
IOException

UserLogManager

public UserLogManager(Configuration conf)
               throws IOException
Create the user log manager to manage user logs on TaskTracker. This constructor is there mainly for unit tests.

Parameters:
conf - The Configuration
Throws:
IOException
Method Detail

getTaskController

public TaskController getTaskController()
Get the taskController for deleting logs.

Returns:
the TaskController

start

public void start()
Starts managing the logs


monitor

protected void monitor()
                throws Exception
Throws:
Exception

processEvent

protected void processEvent(UserLogEvent event)
                     throws IOException
Throws:
IOException

clearOldUserLogs

public void clearOldUserLogs(Configuration conf)
                      throws IOException
Called during TaskTracker restart/re-init.

Parameters:
conf - TT's conf
Throws:
IOException

addLogEvent

public void addLogEvent(UserLogEvent event)
Add the UserLogEvent for processing.

Parameters:
event -

getUserLogCleaner

public UserLogCleaner getUserLogCleaner()
Get UserLogCleaner. This method is called only from unit tests.

Returns:
UserLogCleaner


Copyright © 2009 The Apache Software Foundation