org.apache.hadoop.mapreduce.v2.app.job

Interface Job

All Known Implementing Classes:

JobImpl

public interface Job

Main interface to interact with the job.

Method Summary

Modifier and Type	Method and Description
boolean	checkAccess(org.apache.hadoop.security.UserGroupInformation callerUGI, org.apache.hadoop.mapreduce.JobACL jobOperation)
org.apache.hadoop.mapreduce.Counters	getAllCounters() Get all the counters of this job.
List<org.apache.hadoop.mapreduce.v2.api.records.AMInfo>	getAMInfos()
int	getCompletedMaps()
int	getCompletedReduces()
org.apache.hadoop.fs.Path	getConfFile()
List<String>	getDiagnostics()
int	getFailedMaps()
int	getFailedReduces()
org.apache.hadoop.mapreduce.v2.api.records.JobId	getID()
Map<org.apache.hadoop.mapreduce.JobACL,org.apache.hadoop.security.authorize.AccessControlList>	getJobACLs()
int	getKilledMaps()
int	getKilledReduces()
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()
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,Task>	getTasks()
Map<org.apache.hadoop.mapreduce.v2.api.records.TaskId,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()
void	setJobPriority(org.apache.hadoop.yarn.api.records.Priority priority)
void	setQueueName(String queueName)

Method Detail

getID

org.apache.hadoop.mapreduce.v2.api.records.JobId getID()

getName

String getName()

getState

org.apache.hadoop.mapreduce.v2.api.records.JobState getState()

getReport

org.apache.hadoop.mapreduce.v2.api.records.JobReport getReport()

getAllCounters

org.apache.hadoop.mapreduce.Counters getAllCounters()

Get all the counters of this job. This includes job-counters aggregated together with the counters of each task. This creates a clone of the Counters, so use this judiciously.

Returns:

job-counters and aggregate task-counters

getTasks

Map<org.apache.hadoop.mapreduce.v2.api.records.TaskId,Task> getTasks()

getTasks

Map<org.apache.hadoop.mapreduce.v2.api.records.TaskId,Task> getTasks(org.apache.hadoop.mapreduce.v2.api.records.TaskType taskType)

getTask

Task getTask(org.apache.hadoop.mapreduce.v2.api.records.TaskId taskID)

getDiagnostics

List<String> getDiagnostics()

getTotalMaps

int getTotalMaps()

getTotalReduces

int getTotalReduces()

getCompletedMaps

int getCompletedMaps()

getCompletedReduces

int getCompletedReduces()

getFailedMaps

int getFailedMaps()

getFailedReduces

int getFailedReduces()

getKilledMaps

int getKilledMaps()

getKilledReduces

int getKilledReduces()

getProgress

float getProgress()

isUber

boolean isUber()

getUserName

String getUserName()

getQueueName

String getQueueName()

getConfFile

org.apache.hadoop.fs.Path getConfFile()

Returns:

a path to where the config file for this job is located.

loadConfFile

org.apache.hadoop.conf.Configuration loadConfFile()
                                           throws IOException

Returns:

a parsed version of the config files pointed to by getConfFile().

Throws:

IOException - on any error trying to load the conf file.

getJobACLs

Map<org.apache.hadoop.mapreduce.JobACL,org.apache.hadoop.security.authorize.AccessControlList> getJobACLs()

Returns:

the ACLs for this job for each type of JobACL given.

getTaskAttemptCompletionEvents

org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptCompletionEvent[] getTaskAttemptCompletionEvents(int fromEventId,
                                                                                                       int maxEvents)

getMapAttemptCompletionEvents

org.apache.hadoop.mapred.TaskCompletionEvent[] getMapAttemptCompletionEvents(int startIndex,
                                                                             int maxEvents)

getAMInfos

List<org.apache.hadoop.mapreduce.v2.api.records.AMInfo> getAMInfos()

Returns:

information for MR AppMasters (previously failed and current)

checkAccess

boolean checkAccess(org.apache.hadoop.security.UserGroupInformation callerUGI,
                    org.apache.hadoop.mapreduce.JobACL jobOperation)

setQueueName

void setQueueName(String queueName)

setJobPriority

void setJobPriority(org.apache.hadoop.yarn.api.records.Priority priority)