org.apache.hadoop.mapreduce

类 JobSubmissionFiles

java.lang.Object

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.

字段概要

字段

限定符和类型	字段和说明
static FsPermission	JOB_DIR_PERMISSION
static FsPermission	JOB_FILE_PERMISSION

构造器概要

构造器

构造器和说明
JobSubmissionFiles()

方法概要

方法

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

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

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

字段详细资料

JOB_DIR_PERMISSION

public static final FsPermission JOB_DIR_PERMISSION

JOB_FILE_PERMISSION

public static final FsPermission JOB_FILE_PERMISSION

构造器详细资料

JobSubmissionFiles

public JobSubmissionFiles()

方法详细资料

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.

参数:

jobSubmitDir -

getJobDistCacheArchives

public static Path getJobDistCacheArchives(Path jobSubmitDir)

Get the job distributed cache archives path.

参数:

jobSubmitDir -

getJobDistCacheLibjars

public static Path getJobDistCacheLibjars(Path jobSubmitDir)

Get the job distributed cache libjars path.

参数:

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

参数:

client -

conf -

抛出:

IOException

InterruptedException