org.apache.hadoop.mapreduce
Class JobSubmissionFiles

java.lang.Object
  extended by org.apache.hadoop.mapreduce.JobSubmissionFiles

public class JobSubmissionFiles
extends Object

A utility to manage job submission files.
Note that this class is for framework internal usage only and is not to be used by users directly.


Field Summary
static FsPermission JOB_DIR_PERMISSION
           
static FsPermission JOB_FILE_PERMISSION
           
 
Constructor Summary
JobSubmissionFiles()
           
 
Method Summary
static Path getJobConfPath(Path jobSubmitDir)
          Get the job conf path.
static Path getJobDistCacheArchives(Path jobSubmitDir)
          Get the job distributed cache archives path.
static Path getJobDistCacheFiles(Path jobSubmitDir)
          Get the job distributed cache files path.
static Path getJobDistCacheLibjars(Path jobSubmitDir)
          Get the job distributed cache libjars path.
static Path getJobJar(Path jobSubmitDir)
          Get the job jar path.
static Path getJobSplitFile(Path jobSubmissionDir)
           
static Path getJobSplitMetaFile(Path jobSubmissionDir)
           
static Path getStagingDir(JobClient client, Configuration conf)
          Initializes the staging directory and returns the path.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

JOB_DIR_PERMISSION

public static final FsPermission JOB_DIR_PERMISSION

JOB_FILE_PERMISSION

public static final FsPermission JOB_FILE_PERMISSION
Constructor Detail

JobSubmissionFiles

public JobSubmissionFiles()
Method Detail

getJobSplitFile

public static Path getJobSplitFile(Path jobSubmissionDir)

getJobSplitMetaFile

public static Path getJobSplitMetaFile(Path jobSubmissionDir)

getJobConfPath

public static Path getJobConfPath(Path jobSubmitDir)
Get the job conf path.


getJobJar

public static Path getJobJar(Path jobSubmitDir)
Get the job jar path.


getJobDistCacheFiles

public static Path getJobDistCacheFiles(Path jobSubmitDir)
Get the job distributed cache files path.

Parameters:
jobSubmitDir -

getJobDistCacheArchives

public static Path getJobDistCacheArchives(Path jobSubmitDir)
Get the job distributed cache archives path.

Parameters:
jobSubmitDir -

getJobDistCacheLibjars

public static Path getJobDistCacheLibjars(Path jobSubmitDir)
Get the job distributed cache libjars path.

Parameters:
jobSubmitDir -

getStagingDir

public static Path getStagingDir(JobClient client,
                                 Configuration conf)
                          throws IOException,
                                 InterruptedException
Initializes the staging directory and returns the path. It also keeps track of all necessary ownership & permissions

Parameters:
client -
conf -
Throws:
IOException
InterruptedException


Copyright © 2009 The Apache Software Foundation