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

类 UserLogManager

java.lang.Object

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

public class UserLogManager
extends Object

This manages user logs on the TaskTracker.

构造器概要

构造器

构造器和说明
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.

方法概要

方法

限定符和类型	方法和说明
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

从类继承的方法 java.lang.Object

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

构造器详细资料

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

参数:

conf - The Configuration

taskController - The task controller to delete the log files

抛出:

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.

参数:

conf - The Configuration

抛出:

IOException

方法详细资料

getTaskController

public TaskController getTaskController()

Get the taskController for deleting logs.

返回:

the TaskController

start

public void start()

Starts managing the logs

monitor

protected void monitor()
                throws Exception

抛出:

Exception

processEvent

protected void processEvent(UserLogEvent event)
                     throws IOException

抛出:

IOException

clearOldUserLogs

public void clearOldUserLogs(Configuration conf)
                      throws IOException

Called during TaskTracker restart/re-init.

参数:

conf - TT's conf

抛出:

IOException

addLogEvent

public void addLogEvent(UserLogEvent event)

Add the UserLogEvent for processing.

参数:

event -

getUserLogCleaner

public UserLogCleaner getUserLogCleaner()

Get UserLogCleaner. This method is called only from unit tests.

返回:

UserLogCleaner