public class ReduceAttemptFinishedEvent extends Object implements HistoryEvent
构造器和说明 |
---|
ReduceAttemptFinishedEvent(TaskAttemptID id,
TaskType taskType,
String taskStatus,
long shuffleFinishTime,
long sortFinishTime,
long finishTime,
String hostname,
String state,
Counters counters)
Create an event to record completion of a reduce attempt
|
限定符和类型 | 方法和说明 |
---|---|
TaskAttemptID |
getAttemptId()
Get the attempt id
|
JhCounters |
getCounters()
Get the counters for the attempt
|
EventType |
getEventType()
Get the event type
|
long |
getFinishTime()
Get the finish time of the attempt
|
String |
getHostname()
Get the name of the host where the attempt ran
|
long |
getShuffleFinishTime()
Get the finish time of the shuffle phase
|
long |
getSortFinishTime()
Get the finish time of the sort phase
|
String |
getState()
Get the state string
|
TaskID |
getTaskId()
Get the Task ID
|
String |
getTaskStatus()
Get the task status
|
TaskType |
getTaskType()
Get the task type
|
public ReduceAttemptFinishedEvent(TaskAttemptID id, TaskType taskType, String taskStatus, long shuffleFinishTime, long sortFinishTime, long finishTime, String hostname, String state, Counters counters)
id
- Attempt IdtaskType
- Type of tasktaskStatus
- Status of the taskshuffleFinishTime
- Finish time of the shuffle phasesortFinishTime
- Finish time of the sort phasefinishTime
- Finish time of the attempthostname
- Name of the host where the attempt executedstate
- State of the attemptcounters
- Counters for the attemptpublic TaskID getTaskId()
public TaskAttemptID getAttemptId()
public TaskType getTaskType()
public String getTaskStatus()
public long getSortFinishTime()
public long getShuffleFinishTime()
public long getFinishTime()
public String getHostname()
public String getState()
public JhCounters getCounters()
public EventType getEventType()
getEventType
在接口中 HistoryEvent
Copyright © 2009 The Apache Software Foundation