ZombieJob (Hadoop 1.2.2-SNAPSHOT API)

java.lang.Object
- org.apache.hadoop.tools.rumen.ZombieJob

所有已实现的接口:

JobStory
```
public class ZombieJob
extends Object
implements JobStory
```
ZombieJob is a layer above LoggedJob raw JSON objects. Each ZombieJob object represents a job in job history. For everything that exists in job history, contents are returned unchanged faithfully. To get input splits of a non-exist task, a non-exist task attempt, or an ill-formed task attempt, proper objects are made up from statistical sketches.

构造器概要

构造器
构造器和说明
`ZombieJob(LoggedJob job, ClusterStory cluster)` This constructor creates a `ZombieJob` with the same semantics as the `LoggedJob` passed in this parameter
`ZombieJob(LoggedJob job, ClusterStory cluster, long seed)` This constructor creates a `ZombieJob` with the same semantics as the `LoggedJob` passed in this parameter

方法概要

方法
限定符和类型	方法和说明
`InputSplit[]`	`getInputSplits()` Get the input splits for the job.
`JobConf`	`getJobConf()` Get the `JobConf` for the job.
`JobID`	`getJobID()` Get the job ID
`LoggedJob`	`getLoggedJob()` Get the underlining `LoggedJob` object read directly from the trace.
`TaskAttemptInfo`	`getMapTaskAttemptInfoAdjusted(int taskNumber, int taskAttemptNumber, int locality)` Get a `TaskAttemptInfo` with a `TaskAttemptID` associated with taskType, taskNumber, and taskAttemptNumber.
`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`.
`int`	`getNumLoggedMaps()` Getting the number of map tasks that are actually logged in the trace.
`int`	`getNumLoggedReduces()` Getting the number of reduce tasks that are actually logged in the trace.
`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 a `TaskAttemptInfo` with a `TaskAttemptID` associated with taskType, taskNumber, and taskAttemptNumber.
`TaskInfo`	`getTaskInfo(TaskType taskType, int taskNumber)` Get `TaskInfo` for a given task.
`String`	`getUser()` Get the user who ran the job.

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 构造器详细资料
  - ZombieJob
```
public ZombieJob(LoggedJob job,
         ClusterStory cluster,
         long seed)
```
    This constructor creates a ZombieJob with the same semantics as the LoggedJob passed in this parameter
    
    参数:
    job - The dead job this ZombieJob instance is based on.
    cluster - The cluster topology where the dead job ran on. This argument can be null if we do not have knowledge of the cluster topology.
    seed - Seed for the random number generator for filling in information not available from the ZombieJob.
  - ZombieJob
```
public ZombieJob(LoggedJob job,
         ClusterStory cluster)
```
    This constructor creates a ZombieJob with the same semantics as the LoggedJob passed in this parameter
    
    参数:
    job - The dead job this ZombieJob instance is based on.
    cluster - The cluster topology where the dead job ran on. This argument can be null if we do not have knowledge of the cluster topology.
- 方法详细资料
  - getJobConf
```
public JobConf getJobConf()
```
    从接口复制的说明: JobStory
    
    Get the JobConf for the job.
    
    指定者:
    
    getJobConf 在接口中 JobStory
    
    返回:
    the JobConf for the job
  - getInputSplits
```
public InputSplit[] getInputSplits()
```
    从接口复制的说明: JobStory
    
    Get the input splits for the job.
    
    指定者:
    
    getInputSplits 在接口中 JobStory
    
    返回:
    the input splits for the job
  - getName
```
public String getName()
```
    从接口复制的说明: JobStory
    
    Get the job name.
    
    指定者:
    
    getName 在接口中 JobStory
    
    返回:
    the job name
  - getJobID
```
public JobID getJobID()
```
    从接口复制的说明: JobStory
    
    Get the job ID
    
    指定者:
    
    getJobID 在接口中 JobStory
    
    返回:
    the job ID
  - getNumberMaps
```
public int getNumberMaps()
```
    从接口复制的说明: JobStory
    
    Get the number of maps in the JobStory.
    
    指定者:
    
    getNumberMaps 在接口中 JobStory
    
    返回:
    the number of maps in the Job
  - getNumberReduces
```
public int getNumberReduces()
```
    从接口复制的说明: JobStory
    
    Get the number of reduce in the JobStory.
    
    指定者:
    
    getNumberReduces 在接口中 JobStory
    
    返回:
    the number of reduces in the Job
  - getOutcome
```
public Pre21JobHistoryConstants.Values getOutcome()
```
    从接口复制的说明: JobStory
    
    Get the outcome of the job execution.
    
    指定者:
    
    getOutcome 在接口中 JobStory
    
    返回:
    The outcome of the job execution.
  - getSubmissionTime
```
public long getSubmissionTime()
```
    从接口复制的说明: JobStory
    
    Get the job submission time.
    
    指定者:
    
    getSubmissionTime 在接口中 JobStory
    
    返回:
    the job submission time
  - getQueueName
```
public String getQueueName()
```
    从接口复制的说明: JobStory
    
    Get the queue where the job is submitted.
    
    指定者:
    
    getQueueName 在接口中 JobStory
    
    返回:
    the queue where the job is submitted.
  - getNumLoggedMaps
```
public int getNumLoggedMaps()
```
    Getting the number of map tasks that are actually logged in the trace.
    
    返回:
    The number of map tasks that are actually logged in the trace.
  - getNumLoggedReduces
```
public int getNumLoggedReduces()
```
    Getting the number of reduce tasks that are actually logged in the trace.
    
    返回:
    The number of map tasks that are actually logged in the trace.
  - getUser
```
public String getUser()
```
    从接口复制的说明: JobStory
    
    Get the user who ran the job.
    
    指定者:
    
    getUser 在接口中 JobStory
    
    返回:
    the user who ran the job
  - getLoggedJob
```
public LoggedJob getLoggedJob()
```
    Get the underlining LoggedJob object read directly from the trace. This is mainly for debugging.
    
    返回:
    the underlining LoggedJob object
  - getTaskAttemptInfo
```
public TaskAttemptInfo getTaskAttemptInfo(TaskType taskType,
                                 int taskNumber,
                                 int taskAttemptNumber)
```
    Get a TaskAttemptInfo with a TaskAttemptID associated with taskType, taskNumber, and taskAttemptNumber. This function does not care about locality, and follows the following decision logic: 1. Make up a TaskAttemptInfo if the task attempt is missing in trace, 2. Make up a TaskAttemptInfo if the task attempt has a KILLED final status in trace, 3. Otherwise (final state is SUCCEEDED or FAILED), construct the TaskAttemptInfo from the trace.
    
    指定者:
    
    getTaskAttemptInfo 在接口中 JobStory
    
    参数:
    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
  - getTaskInfo
```
public TaskInfo getTaskInfo(TaskType taskType,
                   int taskNumber)
```
    从接口复制的说明: JobStory
    
    Get TaskInfo for a given task.
    
    指定者:
    
    getTaskInfo 在接口中 JobStory
    
    参数:
    taskType - TaskType of the task
    taskNumber - Partition number of the task
    
    返回:
    the TaskInfo for the given task
  - getMapTaskAttemptInfoAdjusted
```
public TaskAttemptInfo getMapTaskAttemptInfoAdjusted(int taskNumber,
                                            int taskAttemptNumber,
                                            int locality)
```
    Get a TaskAttemptInfo with a TaskAttemptID associated with taskType, taskNumber, and taskAttemptNumber. This function considers locality, and follows the following decision logic: 1. Make up a TaskAttemptInfo if the task attempt is missing in trace, 2. Make up a TaskAttemptInfo if the task attempt has a KILLED final status in trace, 3. If final state is FAILED, construct a TaskAttemptInfo from the trace, without considering locality. 4. If final state is SUCCEEDED, construct a TaskAttemptInfo from the trace, with runtime scaled according to locality in simulation and locality in trace.
    
    指定者:
    
    getMapTaskAttemptInfoAdjusted 在接口中 JobStory
    
    参数:
    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

类 ZombieJob

构造器概要

方法概要

从类继承的方法 java.lang.Object

构造器详细资料

ZombieJob

ZombieJob

方法详细资料

getJobConf

getInputSplits

getName

getJobID

getNumberMaps

getNumberReduces

getOutcome

getSubmissionTime

getQueueName

getNumLoggedMaps

getNumLoggedReduces

getUser

getLoggedJob

getTaskAttemptInfo

getTaskInfo

getMapTaskAttemptInfoAdjusted