org.apache.hadoop.mapreduce.jobhistory
Class MapAttemptFinishedEvent

java.lang.Object
  extended by org.apache.hadoop.mapreduce.jobhistory.MapAttemptFinishedEvent
All Implemented Interfaces:
HistoryEvent

@InterfaceAudience.Private
@InterfaceStability.Unstable
public class MapAttemptFinishedEvent
extends Object
implements HistoryEvent

Event to record successful completion of a map attempt


Constructor Summary
MapAttemptFinishedEvent(TaskAttemptID id, TaskType taskType, String taskStatus, long mapFinishTime, long finishTime, String hostname, int port, String rackName, String state, Counters counters, int[][] allSplits)
          Create an event for successful completion of map attempts
MapAttemptFinishedEvent(TaskAttemptID id, TaskType taskType, String taskStatus, long mapFinishTime, long finishTime, String hostname, String state, Counters counters)
          Deprecated. please use the constructor with an additional argument, an array of splits arrays instead. See ProgressSplitsBlock for an explanation of the meaning of that parameter. Create an event for successful completion of map attempts
 
Method Summary
 TaskAttemptID getAttemptId()
          Get the attempt id
 int[] getClockSplits()
           
 int[] getCpuUsages()
           
 Object getDatum()
          Return the Avro datum wrapped by this.
 EventType getEventType()
          Get the event type
 long getFinishTime()
          Get the attempt finish time
 String getHostname()
          Get the host name
 long getMapFinishTime()
          Get the map phase finish time
 int[] getPhysMemKbytes()
           
 int getPort()
          Get the tracker rpc port
 String getRackName()
          Get the rack name
 String getState()
          Get the state string
 TaskID getTaskId()
          Get the task ID
 String getTaskStatus()
          Get the task status
 TaskType getTaskType()
          Get the task type
 int[] getVMemKbytes()
           
 void setDatum(Object oDatum)
          Set the Avro datum wrapped by this.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MapAttemptFinishedEvent

public MapAttemptFinishedEvent(TaskAttemptID id,
                               TaskType taskType,
                               String taskStatus,
                               long mapFinishTime,
                               long finishTime,
                               String hostname,
                               int port,
                               String rackName,
                               String state,
                               Counters counters,
                               int[][] allSplits)
Create an event for successful completion of map attempts

Parameters:
id - Task Attempt ID
taskType - Type of the task
taskStatus - Status of the task
mapFinishTime - Finish time of the map phase
finishTime - Finish time of the attempt
hostname - Name of the host where the map executed
port - RPC port for the tracker host.
rackName - Name of the rack where the map executed
state - State string for the attempt
counters - Counters for the attempt
allSplits - the "splits", or a pixelated graph of various measurable worker node state variables against progress. Currently there are four; wallclock time, CPU time, virtual memory and physical memory. If you have no splits data, code null for this parameter.

MapAttemptFinishedEvent

@Deprecated
public MapAttemptFinishedEvent(TaskAttemptID id,
                                          TaskType taskType,
                                          String taskStatus,
                                          long mapFinishTime,
                                          long finishTime,
                                          String hostname,
                                          String state,
                                          Counters counters)
Deprecated. please use the constructor with an additional argument, an array of splits arrays instead. See ProgressSplitsBlock for an explanation of the meaning of that parameter. Create an event for successful completion of map attempts

Parameters:
id - Task Attempt ID
taskType - Type of the task
taskStatus - Status of the task
mapFinishTime - Finish time of the map phase
finishTime - Finish time of the attempt
hostname - Name of the host where the map executed
state - State string for the attempt
counters - Counters for the attempt
Method Detail

getDatum

public Object getDatum()
Description copied from interface: HistoryEvent
Return the Avro datum wrapped by this.

Specified by:
getDatum in interface HistoryEvent

setDatum

public void setDatum(Object oDatum)
Description copied from interface: HistoryEvent
Set the Avro datum wrapped by this.

Specified by:
setDatum in interface HistoryEvent

getTaskId

public TaskID getTaskId()
Get the task ID


getAttemptId

public TaskAttemptID getAttemptId()
Get the attempt id


getTaskType

public TaskType getTaskType()
Get the task type


getTaskStatus

public String getTaskStatus()
Get the task status


getMapFinishTime

public long getMapFinishTime()
Get the map phase finish time


getFinishTime

public long getFinishTime()
Get the attempt finish time


getHostname

public String getHostname()
Get the host name


getPort

public int getPort()
Get the tracker rpc port


getRackName

public String getRackName()
Get the rack name


getState

public String getState()
Get the state string


getEventType

public EventType getEventType()
Get the event type

Specified by:
getEventType in interface HistoryEvent

getClockSplits

public int[] getClockSplits()

getCpuUsages

public int[] getCpuUsages()

getVMemKbytes

public int[] getVMemKbytes()

getPhysMemKbytes

public int[] getPhysMemKbytes()


Copyright © 2014 Apache Software Foundation. All Rights Reserved.