Constructor and Description |
---|
CompletedJob(Configuration conf,
JobId jobId,
Path historyFile,
boolean loadTasks,
String userName,
HistoryFileManager.HistoryFileInfo info,
JobACLsManager aclsMgr) |
Modifier and Type | Method and Description |
---|---|
boolean |
checkAccess(UserGroupInformation callerUGI,
JobACL jobOperation) |
Counters |
getAllCounters()
Get all the counters of this job.
|
List<AMInfo> |
getAMInfos() |
int |
getCompletedMaps() |
int |
getCompletedReduces() |
Path |
getConfFile() |
List<String> |
getDiagnostics() |
JobId |
getID() |
Map<JobACL,AccessControlList> |
getJobACLs() |
TaskCompletionEvent[] |
getMapAttemptCompletionEvents(int startIndex,
int maxEvents) |
String |
getName() |
float |
getProgress() |
String |
getQueueName() |
JobReport |
getReport() |
JobState |
getState() |
Task |
getTask(TaskId taskId) |
TaskAttemptCompletionEvent[] |
getTaskAttemptCompletionEvents(int fromEventId,
int maxEvents) |
Map<TaskId,Task> |
getTasks() |
Map<TaskId,Task> |
getTasks(TaskType taskType) |
int |
getTotalMaps() |
int |
getTotalReduces() |
String |
getUserName() |
boolean |
isUber() |
Configuration |
loadConfFile() |
protected void |
loadFullHistoryData(boolean loadTasks,
Path historyFileAbsolute) |
public CompletedJob(Configuration conf, JobId jobId, Path historyFile, boolean loadTasks, String userName, HistoryFileManager.HistoryFileInfo info, JobACLsManager aclsMgr) throws IOException
IOException
public int getCompletedMaps()
getCompletedMaps
in interface Job
public int getCompletedReduces()
getCompletedReduces
in interface Job
public Counters getAllCounters()
Job
getAllCounters
in interface Job
public float getProgress()
getProgress
in interface Job
public TaskAttemptCompletionEvent[] getTaskAttemptCompletionEvents(int fromEventId, int maxEvents)
getTaskAttemptCompletionEvents
in interface Job
public TaskCompletionEvent[] getMapAttemptCompletionEvents(int startIndex, int maxEvents)
getMapAttemptCompletionEvents
in interface Job
protected void loadFullHistoryData(boolean loadTasks, Path historyFileAbsolute) throws IOException
IOException
public List<String> getDiagnostics()
getDiagnostics
in interface Job
public String getQueueName()
getQueueName
in interface Job
public int getTotalMaps()
getTotalMaps
in interface Job
public int getTotalReduces()
getTotalReduces
in interface Job
public boolean checkAccess(UserGroupInformation callerUGI, JobACL jobOperation)
checkAccess
in interface Job
public Map<JobACL,AccessControlList> getJobACLs()
getJobACLs
in interface Job
public String getUserName()
getUserName
in interface Job
public Path getConfFile()
getConfFile
in interface Job
public Configuration loadConfFile() throws IOException
loadConfFile
in interface Job
Job.getConfFile()
.IOException
- on any error trying to load the conf file.public List<AMInfo> getAMInfos()
getAMInfos
in interface Job
Copyright © 2013 Apache Software Foundation. All rights reserved.