org.apache.hadoop.tools.rumen

接口 JobStory

所有已知实现类:

ZombieJob

public interface JobStory

JobStory represents the runtime information available for a completed Map-Reduce job.

方法概要

方法

限定符和类型	方法和说明
InputSplit[]	getInputSplits() Get the input splits for the job.
JobConf	getJobConf() Get the JobConf for the job.
JobID	getJobID() Get the job ID
TaskAttemptInfo	getMapTaskAttemptInfoAdjusted(int taskNumber, int taskAttemptNumber, int locality) Get TaskAttemptInfo for a given task-attempt, considering impact of locality.
String	getName() Get the job name.
int	getNumberMaps() Get the number of maps in the JobStory.
int	getNumberReduces() Get the number of reduce in the JobStory.
Pre21JobHistoryConstants.Values	getOutcome() Get the outcome of the job execution.
String	getQueueName() Get the queue where the job is submitted.
long	getSubmissionTime() Get the job submission time.
TaskAttemptInfo	getTaskAttemptInfo(TaskType taskType, int taskNumber, int taskAttemptNumber) Get TaskAttemptInfo for a given task-attempt, without regard to impact of locality (e.g. not needed to make scheduling decisions).
TaskInfo	getTaskInfo(TaskType taskType, int taskNumber) Get TaskInfo for a given task.
String	getUser() Get the user who ran the job.

方法详细资料

getJobConf

JobConf getJobConf()

Get the JobConf for the job.

返回:

the JobConf for the job

getName

String getName()

Get the job name.

返回:

the job name

getJobID

JobID getJobID()

Get the job ID

返回:

the job ID

getUser

String getUser()

Get the user who ran the job.

返回:

the user who ran the job

getSubmissionTime

long getSubmissionTime()

Get the job submission time.

返回:

the job submission time

getNumberMaps

int getNumberMaps()

Get the number of maps in the JobStory.

返回:

the number of maps in the Job

getNumberReduces

int getNumberReduces()

Get the number of reduce in the JobStory.

返回:

the number of reduces in the Job

getInputSplits

InputSplit[] getInputSplits()

Get the input splits for the job.

返回:

the input splits for the job

getTaskInfo

TaskInfo getTaskInfo(TaskType taskType,
                   int taskNumber)

Get TaskInfo for a given task.

参数:

taskType - TaskType of the task

taskNumber - Partition number of the task

返回:

the TaskInfo for the given task

getTaskAttemptInfo

TaskAttemptInfo getTaskAttemptInfo(TaskType taskType,
                                 int taskNumber,
                                 int taskAttemptNumber)

Get TaskAttemptInfo for a given task-attempt, without regard to impact of locality (e.g. not needed to make scheduling decisions).

参数:

taskType - TaskType of the task-attempt

taskNumber - Partition number of the task-attempt

taskAttemptNumber - Attempt number of the task

返回:

the TaskAttemptInfo for the given task-attempt

getMapTaskAttemptInfoAdjusted

TaskAttemptInfo getMapTaskAttemptInfoAdjusted(int taskNumber,
                                            int taskAttemptNumber,
                                            int locality)

Get TaskAttemptInfo for a given task-attempt, considering impact of locality.

参数:

taskNumber - Partition number of the task-attempt

taskAttemptNumber - Attempt number of the task

locality - Data locality of the task as scheduled in simulation

返回:

the TaskAttemptInfo for the given task-attempt

getOutcome

Pre21JobHistoryConstants.Values getOutcome()

Get the outcome of the job execution.

返回:

The outcome of the job execution.

getQueueName

String getQueueName()

Get the queue where the job is submitted.

返回:

the queue where the job is submitted.