public class CompletedJob extends Object implements org.apache.hadoop.mapreduce.v2.app.job.Job
Constructor and Description |
---|
CompletedJob(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.mapreduce.v2.api.records.JobId jobId,
org.apache.hadoop.fs.Path historyFile,
boolean loadTasks,
String userName,
HistoryFileManager.HistoryFileInfo info,
org.apache.hadoop.mapred.JobACLsManager aclsMgr) |
Modifier and Type | Method and Description |
---|---|
boolean |
checkAccess(org.apache.hadoop.security.UserGroupInformation callerUGI,
org.apache.hadoop.mapreduce.JobACL jobOperation) |
protected org.apache.hadoop.mapreduce.jobhistory.JobHistoryParser |
createJobHistoryParser(org.apache.hadoop.fs.Path historyFileAbsolute) |
org.apache.hadoop.mapreduce.Counters |
getAllCounters() |
List<org.apache.hadoop.mapreduce.v2.api.records.AMInfo> |
getAMInfos() |
int |
getCompletedMaps() |
int |
getCompletedReduces() |
org.apache.hadoop.fs.Path |
getConfFile() |
List<String> |
getDiagnostics() |
org.apache.hadoop.mapreduce.v2.api.records.JobId |
getID() |
Map<org.apache.hadoop.mapreduce.JobACL,org.apache.hadoop.security.authorize.AccessControlList> |
getJobACLs() |
org.apache.hadoop.mapred.TaskCompletionEvent[] |
getMapAttemptCompletionEvents(int startIndex,
int maxEvents) |
String |
getName() |
float |
getProgress() |
String |
getQueueName() |
org.apache.hadoop.mapreduce.v2.api.records.JobReport |
getReport() |
org.apache.hadoop.mapreduce.v2.api.records.JobState |
getState() |
org.apache.hadoop.mapreduce.v2.app.job.Task |
getTask(org.apache.hadoop.mapreduce.v2.api.records.TaskId taskId) |
org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptCompletionEvent[] |
getTaskAttemptCompletionEvents(int fromEventId,
int maxEvents) |
Map<org.apache.hadoop.mapreduce.v2.api.records.TaskId,org.apache.hadoop.mapreduce.v2.app.job.Task> |
getTasks() |
Map<org.apache.hadoop.mapreduce.v2.api.records.TaskId,org.apache.hadoop.mapreduce.v2.app.job.Task> |
getTasks(org.apache.hadoop.mapreduce.v2.api.records.TaskType taskType) |
int |
getTotalMaps() |
int |
getTotalReduces() |
String |
getUserName() |
boolean |
isUber() |
org.apache.hadoop.conf.Configuration |
loadConfFile() |
protected void |
loadFullHistoryData(boolean loadTasks,
org.apache.hadoop.fs.Path historyFileAbsolute) |
void |
setJobPriority(org.apache.hadoop.yarn.api.records.Priority priority) |
void |
setQueueName(String queueName) |
public CompletedJob(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.v2.api.records.JobId jobId, org.apache.hadoop.fs.Path historyFile, boolean loadTasks, String userName, HistoryFileManager.HistoryFileInfo info, org.apache.hadoop.mapred.JobACLsManager aclsMgr) throws IOException
IOException
public int getCompletedMaps()
getCompletedMaps
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public int getCompletedReduces()
getCompletedReduces
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public org.apache.hadoop.mapreduce.Counters getAllCounters()
getAllCounters
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public org.apache.hadoop.mapreduce.v2.api.records.JobId getID()
getID
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public org.apache.hadoop.mapreduce.v2.api.records.JobReport getReport()
getReport
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public float getProgress()
getProgress
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public org.apache.hadoop.mapreduce.v2.api.records.JobState getState()
getState
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public org.apache.hadoop.mapreduce.v2.app.job.Task getTask(org.apache.hadoop.mapreduce.v2.api.records.TaskId taskId)
getTask
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptCompletionEvent[] getTaskAttemptCompletionEvents(int fromEventId, int maxEvents)
getTaskAttemptCompletionEvents
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public org.apache.hadoop.mapred.TaskCompletionEvent[] getMapAttemptCompletionEvents(int startIndex, int maxEvents)
getMapAttemptCompletionEvents
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public Map<org.apache.hadoop.mapreduce.v2.api.records.TaskId,org.apache.hadoop.mapreduce.v2.app.job.Task> getTasks()
getTasks
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
protected org.apache.hadoop.mapreduce.jobhistory.JobHistoryParser createJobHistoryParser(org.apache.hadoop.fs.Path historyFileAbsolute) throws IOException
IOException
protected void loadFullHistoryData(boolean loadTasks, org.apache.hadoop.fs.Path historyFileAbsolute) throws IOException
IOException
public List<String> getDiagnostics()
getDiagnostics
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public String getName()
getName
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public String getQueueName()
getQueueName
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public int getTotalMaps()
getTotalMaps
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public int getTotalReduces()
getTotalReduces
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public boolean isUber()
isUber
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public Map<org.apache.hadoop.mapreduce.v2.api.records.TaskId,org.apache.hadoop.mapreduce.v2.app.job.Task> getTasks(org.apache.hadoop.mapreduce.v2.api.records.TaskType taskType)
getTasks
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public boolean checkAccess(org.apache.hadoop.security.UserGroupInformation callerUGI, org.apache.hadoop.mapreduce.JobACL jobOperation)
checkAccess
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public Map<org.apache.hadoop.mapreduce.JobACL,org.apache.hadoop.security.authorize.AccessControlList> getJobACLs()
getJobACLs
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public String getUserName()
getUserName
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public org.apache.hadoop.fs.Path getConfFile()
getConfFile
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public org.apache.hadoop.conf.Configuration loadConfFile() throws IOException
loadConfFile
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
IOException
public List<org.apache.hadoop.mapreduce.v2.api.records.AMInfo> getAMInfos()
getAMInfos
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public void setQueueName(String queueName)
setQueueName
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
public void setJobPriority(org.apache.hadoop.yarn.api.records.Priority priority)
setJobPriority
in interface org.apache.hadoop.mapreduce.v2.app.job.Job
Copyright © 2017 Apache Software Foundation. All Rights Reserved.