| 
||||||||||
| 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 | |||||||||