org.apache.hadoop.mapreduce.server.tasktracker

类 Localizer

java.lang.Object

org.apache.hadoop.mapreduce.server.tasktracker.Localizer

public class Localizer
extends Object

NOTE: This class is internal only and not intended for users!!

构造器概要

构造器

构造器和说明
Localizer(FileSystem fileSys, String[] lDirs) Create a Localizer instance

方法概要

方法

限定符和类型	方法和说明
void	initializeAttemptDirs(String user, String jobId, String attemptId) Create taskDirs on all the disks.
void	initializeUserDirs(String user) Initialize the local directories for a particular user on this TT.

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

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

构造器详细资料

Localizer

public Localizer(FileSystem fileSys,
         String[] lDirs)

Create a Localizer instance

参数:

fileSys -

lDirs -

方法详细资料

initializeUserDirs

public void initializeUserDirs(String user)
                        throws IOException

Initialize the local directories for a particular user on this TT. This involves creation and setting permissions of the following directories

• $mapred.local.dir/taskTracker/$user
• $mapred.local.dir/taskTracker/$user/jobcache
• $mapred.local.dir/taskTracker/$user/distcache

参数:

user -

抛出:

IOException

initializeAttemptDirs

public void initializeAttemptDirs(String user,
                         String jobId,
                         String attemptId)
                           throws IOException

Create taskDirs on all the disks. Otherwise, in some cases, like when LinuxTaskController is in use, child might wish to balance load across disks but cannot itself create attempt directory because of the fact that job directory is writable only by the TT.

参数:

user -

jobId -

attemptId -

抛出:

IOException