Modifier and Type | Method and Description |
---|---|
protected Job |
MRAppMaster.createJob(Configuration conf,
JobStateInternal forcedState,
String diagnostic)
Create and initialize (but don't start) a single job.
|
Job |
AppContext.getJob(JobId jobID) |
Job |
MRAppMaster.RunningAppContext.getJob(JobId jobID) |
Modifier and Type | Method and Description |
---|---|
Map<JobId,Job> |
AppContext.getAllJobs() |
Map<JobId,Job> |
MRAppMaster.RunningAppContext.getAllJobs() |
Modifier and Type | Class and Description |
---|---|
class |
JobImpl
Implementation of Job interface.
|
Modifier and Type | Method and Description |
---|---|
void |
MRAppMetrics.completedJob(Job job) |
void |
MRAppMetrics.endPreparingJob(Job job) |
void |
MRAppMetrics.endRunningJob(Job job) |
void |
MRAppMetrics.failedJob(Job job) |
void |
MRAppMetrics.killedJob(Job job) |
void |
MRAppMetrics.preparingJob(Job job) |
void |
MRAppMetrics.runningJob(Job job) |
void |
MRAppMetrics.submittedJob(Job job) |
Modifier and Type | Method and Description |
---|---|
protected Job |
RMCommunicator.getJob() |
Modifier and Type | Field and Description |
---|---|
protected Job |
SingleCounterBlock.job |
Modifier and Type | Method and Description |
---|---|
Job |
App.getJob() |
static Job |
AMWebServices.getJobFromJobIdString(String jid,
AppContext appCtx)
convert a job id string to an actual job and handle all the error checking.
|
Modifier and Type | Method and Description |
---|---|
static Task |
AMWebServices.getTaskFromTaskIdString(String tid,
Job job)
convert a task id string to an actual task and handle all the error
checking.
|
Constructor and Description |
---|
ConfInfo(Job job) |
JobCounterInfo(AppContext ctx,
Job job) |
JobInfo(Job job,
Boolean hasAccess) |
Modifier and Type | Class and Description |
---|---|
class |
CompletedJob
Loads the basic job level data upfront.
|
class |
PartialJob |
Modifier and Type | Method and Description |
---|---|
Job |
HistoryStorage.getFullJob(JobId jobId)
Get a fully parsed job.
|
Job |
CachedHistoryStorage.getFullJob(JobId jobId) |
Job |
JobHistory.getJob(JobId jobId) |
Job |
HistoryFileManager.HistoryFileInfo.loadJob()
Parse a job from the JobHistoryFile, if the underlying file is not going
to be deleted.
|
Modifier and Type | Method and Description |
---|---|
Map<JobId,Job> |
JobHistory.getAllJobs() |
Map<JobId,Job> |
HistoryContext.getAllJobs(ApplicationId appID) |
Map<JobId,Job> |
JobHistory.getAllJobs(ApplicationId appID) |
Map<JobId,Job> |
HistoryStorage.getAllPartialJobs()
Get all of the cached jobs.
|
Map<JobId,Job> |
CachedHistoryStorage.getAllPartialJobs() |
Modifier and Type | Method and Description |
---|---|
static JobsInfo |
CachedHistoryStorage.getPartialJobs(Collection<Job> jobs,
Long offset,
Long count,
String user,
String queue,
Long sBegin,
Long sEnd,
Long fBegin,
Long fEnd,
JobState jobState) |
Constructor and Description |
---|
JobInfo(Job job) |
Copyright © 2013 Apache Software Foundation. All rights reserved.