|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use JobID | |
---|---|
org.apache.hadoop.filecache | |
org.apache.hadoop.mapred | A software framework for easily writing applications which process vast amounts of data (multi-terabyte data-sets) parallelly on large clusters (thousands of nodes) built of commodity hardware in a reliable, fault-tolerant manner. |
org.apache.hadoop.mapreduce | |
org.apache.hadoop.mapreduce.lib.jobcontrol | |
org.apache.hadoop.mapreduce.security.token | |
org.apache.hadoop.mapreduce.server.tasktracker.userlogs | |
org.apache.hadoop.mapreduce.split |
Uses of JobID in org.apache.hadoop.filecache |
---|
Methods in org.apache.hadoop.filecache with parameters of type JobID | |
---|---|
protected TaskDistributedCacheManager |
TrackerDistributedCacheManager.getTaskDistributedCacheManager(JobID jobId)
|
TaskDistributedCacheManager |
TrackerDistributedCacheManager.newTaskDistributedCacheManager(JobID jobId,
Configuration taskConf)
|
void |
TrackerDistributedCacheManager.removeTaskDistributedCacheManager(JobID jobId)
|
void |
TrackerDistributedCacheManager.setArchiveSizes(JobID jobId,
long[] sizes)
Set the sizes for any archives, files, or directories in the private distributed cache. |
Uses of JobID in org.apache.hadoop.mapred |
---|
Subclasses of JobID in org.apache.hadoop.mapred | |
---|---|
class |
JobID
JobID represents the immutable and unique identifier for the job. |
Methods in org.apache.hadoop.mapred with parameters of type JobID | |
---|---|
void |
UserLogCleaner.deleteJobLogs(JobID jobid)
|
static JobID |
JobID.downgrade(JobID old)
Downgrade a new JobID to an old one |
static File |
TaskLog.getJobDir(JobID jobid)
Get the user log directory for the job jobid. |
void |
JobLocalizer.localizeJobFiles(JobID jobid,
JobConf jConf,
Path localJobFile,
Path localJobTokenFile,
TaskUmbilicalProtocol taskTracker)
|
void |
JobLocalizer.localizeJobFiles(JobID jobid,
JobConf jConf,
Path localJobTokenFile,
TaskUmbilicalProtocol taskTracker)
|
void |
UserLogCleaner.markJobLogsForDeletion(long jobCompletionTime,
int retainHours,
JobID jobid)
Adds job user-log directory to cleanup thread to delete logs after user-log retain hours. |
void |
UserLogCleaner.unmarkJobFromLogDeletion(JobID jobid)
Remove job from user log deletion. |
void |
TaskUmbilicalProtocol.updatePrivateDistributedCacheSizes(JobID jobId,
long[] sizes)
The job initializer needs to report the sizes of the archive objects and directories in the private distributed cache. |
void |
TaskTracker.updatePrivateDistributedCacheSizes(JobID jobId,
long[] sizes)
|
Constructors in org.apache.hadoop.mapred with parameters of type JobID | |
---|---|
JobProfile(String user,
JobID jobid,
String jobFile,
String url,
String name)
Construct a JobProfile the userid, jobid,
job config-file, job-details url and job name. |
|
JobProfile(String user,
JobID jobid,
String jobFile,
String url,
String name,
String queueName)
Construct a JobProfile the userid, jobid,
job config-file, job-details url and job name. |
|
TaskID(JobID jobId,
boolean isMap,
int id)
Constructs a TaskID object from given JobID . |
Uses of JobID in org.apache.hadoop.mapreduce |
---|
Methods in org.apache.hadoop.mapreduce that return JobID | |
---|---|
static JobID |
JobID.forName(String str)
Construct a JobId object from given string |
JobID |
JobContext.getJobID()
Get the unique ID for the job. |
JobID |
TaskAttemptID.getJobID()
Returns the JobID object that this task attempt belongs to |
JobID |
TaskID.getJobID()
Returns the JobID object that this tip belongs to |
Constructors in org.apache.hadoop.mapreduce with parameters of type JobID | |
---|---|
JobContext(Configuration conf,
JobID jobId)
|
|
TaskID(JobID jobId,
boolean isMap,
int id)
Constructs a TaskID object from given JobID . |
Uses of JobID in org.apache.hadoop.mapreduce.lib.jobcontrol |
---|
Methods in org.apache.hadoop.mapreduce.lib.jobcontrol that return JobID | |
---|---|
JobID |
ControlledJob.getMapredJobID()
|
Uses of JobID in org.apache.hadoop.mapreduce.security.token |
---|
Methods in org.apache.hadoop.mapreduce.security.token with parameters of type JobID | |
---|---|
static void |
DelegationTokenRenewal.registerDelegationTokensForRenewal(JobID jobId,
Credentials ts,
Configuration conf)
|
static void |
DelegationTokenRenewal.removeDelegationTokenRenewalForJob(JobID jobId)
removing DT for completed jobs |
Uses of JobID in org.apache.hadoop.mapreduce.server.tasktracker.userlogs |
---|
Methods in org.apache.hadoop.mapreduce.server.tasktracker.userlogs that return JobID | |
---|---|
JobID |
JobCompletedEvent.getJobID()
Get the job id. |
JobID |
JobStartedEvent.getJobID()
Get the job id. |
JobID |
DeleteJobEvent.getJobID()
Get the jobid. |
Constructors in org.apache.hadoop.mapreduce.server.tasktracker.userlogs with parameters of type JobID | |
---|---|
DeleteJobEvent(JobID jobid)
Create the event to delete job log directory. |
|
JobCompletedEvent(JobID jobid,
long jobCompletionTime,
int retainHours)
Create the event for job completion. |
|
JobStartedEvent(JobID jobid)
Create the event to inform the job has started. |
Uses of JobID in org.apache.hadoop.mapreduce.split |
---|
Methods in org.apache.hadoop.mapreduce.split with parameters of type JobID | |
---|---|
static JobSplit.TaskSplitMetaInfo[] |
SplitMetaInfoReader.readSplitMetaInfo(JobID jobId,
FileSystem fs,
Configuration conf,
Path jobSubmitDir)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |