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

Class UserLogManager

java.lang.Object

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

public class UserLogManager
extends java.lang.Object

This manages user logs on the TaskTracker.

Constructor Summary

Constructors

Constructor and Description
UserLogManager(org.apache.hadoop.conf.Configuration conf) Create the user log manager to manage user logs on TaskTracker.
UserLogManager(org.apache.hadoop.conf.Configuration conf, TaskController taskController) Create the user log manager to manage user logs on TaskTracker.

Method Summary

Methods

Modifier and Type	Method and Description
void	addLogEvent(UserLogEvent event) Add the UserLogEvent for processing.
void	clearOldUserLogs(org.apache.hadoop.conf.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(org.apache.hadoop.conf.Configuration conf,
              TaskController taskController)
               throws java.io.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:

java.io.IOException

UserLogManager

public UserLogManager(org.apache.hadoop.conf.Configuration conf)
               throws java.io.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:

java.io.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 java.lang.Exception

Throws:

java.lang.Exception

processEvent

protected void processEvent(UserLogEvent event)
                     throws java.io.IOException

Throws:

java.io.IOException

clearOldUserLogs

public void clearOldUserLogs(org.apache.hadoop.conf.Configuration conf)
                      throws java.io.IOException

Called during TaskTracker restart/re-init.

Parameters:

conf - TT's conf

Throws:

java.io.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