@InterfaceAudience.Private public class JobSubmissionFiles extends Object
Modifier and Type | Field and Description |
---|---|
static FsPermission |
JOB_DIR_PERMISSION |
static FsPermission |
JOB_FILE_PERMISSION |
Constructor and Description |
---|
JobSubmissionFiles() |
Modifier and Type | Method and Description |
---|---|
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(Cluster cluster,
Configuration conf)
Initializes the staging directory and returns the path.
|
public static final FsPermission JOB_DIR_PERMISSION
public static final FsPermission JOB_FILE_PERMISSION
public static Path getJobDistCacheFiles(Path jobSubmitDir)
jobSubmitDir
- public static Path getJobDistCacheArchives(Path jobSubmitDir)
jobSubmitDir
- public static Path getJobDistCacheLibjars(Path jobSubmitDir)
jobSubmitDir
- public static Path getStagingDir(Cluster cluster, Configuration conf) throws IOException, InterruptedException
cluster
- conf
- IOException
InterruptedException
Copyright © 2013 Apache Software Foundation. All rights reserved.