Uses of Class
org.apache.hadoop.mapred.JobID

Packages that use JobID

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.mapred.jobcontrol	Utilities for managing dependent jobs.
org.apache.hadoop.streaming	Hadoop Streaming is a utility which allows users to create and run Map-Reduce jobs with any executables (e.g.

Uses of JobID in org.apache.hadoop.mapred

Methods in org.apache.hadoop.mapred that return JobID

static JobID	JobID.downgrade(JobID old) Downgrade a new JobID to an old one
static JobID	JobID.forName(String str) Construct a JobId object from given string
JobID	RunningJob.getID() Get the job identifier.
JobID	TaskID.getJobID()
JobID	TaskAttemptID.getJobID()
JobID	JobStatus.getJobID()
JobID	JobProfile.getJobID() Get the job id.
JobID	Task.getJobID() Get the job name for this task.
JobID	JobInProgress.getJobID()
JobID	JobTracker.getNewJobId() Allocates a new JobId string.
static JobID	JobID.read(DataInput in) Deprecated.

Methods in org.apache.hadoop.mapred with parameters of type JobID

void	JobClient.displayTasks(JobID jobId, String type, String state) Display the information about a job's tasks, of a particular type and in a particular state
TaskReport[]	JobTracker.getCleanupTaskReports(JobID jobid)
TaskReport[]	JobClient.getCleanupTaskReports(JobID jobId) Get the information of the current state of the cleanup tasks of a job.
static String	JobHistory.getHistoryFilePath(JobID jobId) Given the job id, return the history file path from the cache
JobInProgress	JobTracker.getJob(JobID jobid)
RunningJob	JobClient.getJob(JobID jobid) Get an RunningJob object to track an ongoing job.
Counters	JobTracker.getJobCounters(JobID jobid)
static String	JobHistory.JobInfo.getJobHistoryFileName(JobConf jobConf, JobID id) Recover the job history filename from the history folder.
JobProfile	JobTracker.getJobProfile(JobID jobid)
JobStatus	JobTracker.getJobStatus(JobID jobid)
static String	JobTracker.getLocalJobFilePath(JobID jobId) Get the localized job file path on the job trackers local file system
static String	JobHistory.JobInfo.getLocalJobFilePath(JobID jobId) Get the path of the locally stored job file
MapTaskCompletionEventsUpdate	TaskUmbilicalProtocol.getMapCompletionEvents(JobID jobId, int fromIndex, int maxLocs, TaskAttemptID id, org.apache.hadoop.mapred.JvmContext jvmContext) Called by a reduce task to get the map output locations for finished maps.
MapTaskCompletionEventsUpdate	TaskTracker.getMapCompletionEvents(JobID jobId, int fromEventId, int maxLocs, TaskAttemptID id, org.apache.hadoop.mapred.JvmContext jvmContext)
TaskReport[]	JobTracker.getMapTaskReports(JobID jobid)
TaskReport[]	JobClient.getMapTaskReports(JobID jobId) Get the information of the current state of the map tasks of a job.
TaskReport[]	JobTracker.getReduceTaskReports(JobID jobid)
TaskReport[]	JobClient.getReduceTaskReports(JobID jobId) Get the information of the current state of the reduce tasks of a job.
TaskReport[]	JobTracker.getSetupTaskReports(JobID jobid)
TaskReport[]	JobClient.getSetupTaskReports(JobID jobId) Get the information of the current state of the setup tasks of a job.
TaskCompletionEvent[]	JobTracker.getTaskCompletionEvents(JobID jobid, int fromEventId, int maxEvents)
void	Task.initialize(JobConf job, JobID id, Reporter reporter, boolean useNewApi)
void	JobTracker.killJob(JobID jobid)
static void	JobHistory.JobInfo.logFailed(JobID jobid, long timestamp, int finishedMaps, int finishedReduces, String failReason) Logs job failed event.
static void	JobHistory.JobInfo.logFinished(JobID jobId, long finishTime, int finishedMaps, int finishedReduces, int failedMaps, int failedReduces, Counters mapCounters, Counters reduceCounters, Counters counters) Log job finished.
static void	JobHistory.JobInfo.logInited(JobID jobId, long startTime, int totalMaps, int totalReduces) Logs launch time of job.
static void	JobHistory.JobInfo.logJobInfo(JobID jobid, long submitTime, long launchTime)
static void	JobHistory.JobInfo.logJobInfo(JobID jobid, long submitTime, long launchTime, int restartCount) Deprecated. Use JobHistory.JobInfo.logJobInfo(JobID, long, long) instead.
static void	JobHistory.JobInfo.logJobPriority(JobID jobid, JobPriority priority) Log job's priority.
static void	JobHistory.JobInfo.logKilled(JobID jobid, long timestamp, int finishedMaps, int finishedReduces) Logs job killed event.
static void	JobHistory.JobInfo.logStarted(JobID jobId) Logs job as running
static void	JobHistory.JobInfo.logStarted(JobID jobId, long startTime, int totalMaps, int totalReduces) Deprecated. Use JobHistory.JobInfo.logInited(JobID, long, int, int) and JobHistory.JobInfo.logStarted(JobID)
static void	JobHistory.JobInfo.logSubmitted(JobID jobId, JobConf jobConf, String jobConfPath, long submitTime) Deprecated. Use JobHistory.JobInfo.logSubmitted(JobID, JobConf, String, long, boolean) instead.
static void	JobHistory.JobInfo.logSubmitted(JobID jobId, JobConf jobConf, String jobConfPath, long submitTime, boolean restarted)
void	JobTracker.setJobPriority(JobID jobid, String priority)
JobStatus	JobTracker.submitJob(JobID jobId, String jobSubmitDir, Credentials ts) JobTracker.submitJob() kicks off a new job.

Constructors in org.apache.hadoop.mapred with parameters of type JobID

JobInProgress(JobID jobid, JobConf conf, JobTracker tracker)
Create an almost empty JobInProgress, which can be used only for tests

JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp)
Create a job status object for a given jobid.

JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState)
Create a job status object for a given jobid.

JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp)
Create a job status object for a given jobid.

JobStatus(JobID jobid, float mapProgress, float reduceProgress, int runState)
Create a job status object for a given jobid.

Uses of JobID in org.apache.hadoop.mapred.jobcontrol

Methods in org.apache.hadoop.mapred.jobcontrol that return JobID

JobID

Job.getAssignedJobID()

Methods in org.apache.hadoop.mapred.jobcontrol with parameters of type JobID

void	Job.setAssignedJobID(JobID mapredJobID) Set the mapred ID for this job as assigned by the mapred framework.

Uses of JobID in org.apache.hadoop.streaming

Fields in org.apache.hadoop.streaming declared as JobID

protected JobID

StreamJob.jobId_