public class Localizer
extends java.lang.Object
Constructor and Description |
---|
Localizer(org.apache.hadoop.fs.FileSystem fileSys,
java.lang.String[] lDirs)
Create a Localizer instance
|
Modifier and Type | Method and Description |
---|---|
void |
initializeAttemptDirs(java.lang.String user,
java.lang.String jobId,
java.lang.String attemptId)
Create taskDirs on all the disks.
|
void |
initializeJobDirs(java.lang.String user,
JobID jobId)
Prepare the job directories for a given job.
|
void |
initializeJobLogDir(JobID jobId)
Create job log directory and set appropriate permissions for the directory.
|
void |
initializeUserDirs(java.lang.String user)
Initialize the local directories for a particular user on this TT.
|
public Localizer(org.apache.hadoop.fs.FileSystem fileSys, java.lang.String[] lDirs)
fileSys
- lDirs
- public void initializeUserDirs(java.lang.String user) throws java.io.IOException
user
- java.io.IOException
public void initializeJobDirs(java.lang.String user, JobID jobId) throws java.io.IOException
TaskController.initializeJob(java.lang.String, java.lang.String, org.apache.hadoop.fs.Path, org.apache.hadoop.fs.Path, org.apache.hadoop.mapred.TaskUmbilicalProtocol, java.net.InetSocketAddress)
is run at a
later time to set proper private permissions on the job directories. user
- jobId
- java.io.IOException
public void initializeAttemptDirs(java.lang.String user, java.lang.String jobId, java.lang.String attemptId) throws java.io.IOException
user
- jobId
- attemptId
- java.io.IOException
public void initializeJobLogDir(JobID jobId) throws java.io.IOException
jobId
- java.io.IOException
Copyright © 2009 The Apache Software Foundation