Package org.apache.hadoop.mapreduce

Class TaskCompletionEvent

java.lang.Object
org.apache.hadoop.mapreduce.TaskCompletionEvent
All Implemented Interfaces:
Writable
Direct Known Subclasses:
TaskCompletionEvent
@Public @Evolving public class TaskCompletionEvent extends Object implements Writable
This is used to track task completion events on job tracker.

  • Field Details

  • Constructor Details

    • TaskCompletionEvent

      public TaskCompletionEvent()
      Default constructor for Writable.

    • TaskCompletionEvent

      public TaskCompletionEvent(int eventId, TaskAttemptID taskId, int idWithinJob, boolean isMap, TaskCompletionEvent.Status status, String taskTrackerHttp)
      Constructor. eventId should be created externally and incremented per event for each job.
      Parameters:
      eventId - event id, event id should be unique and assigned in incrementally, starting from 0.
      taskId - task id
      status - task's status
      taskTrackerHttp - task tracker's host:port for http.

  • Method Details

    • getEventId

      public int getEventId()
      Returns event Id.
      Returns:
      event id

    • getTaskAttemptId

      public TaskAttemptID getTaskAttemptId()
      Returns task id.
      Returns:
      task id

    • getStatus

      public TaskCompletionEvent.Status getStatus()
      Returns TaskCompletionEvent.Status
      Returns:
      task completion status

    • getTaskTrackerHttp

      public String getTaskTrackerHttp()
      http location of the tasktracker where this task ran.
      Returns:
      http location of tasktracker user logs

    • getTaskRunTime

      public int getTaskRunTime()
      Returns time (in millisec) the task took to complete.

    • setTaskRunTime

      protected void setTaskRunTime(int taskCompletionTime)
      Set the task completion time
      Parameters:
      taskCompletionTime - time (in millisec) the task took to complete

    • setEventId

      protected void setEventId(int eventId)
      set event Id. should be assigned incrementally starting from 0.
      Parameters:
      eventId -

    • setTaskAttemptId

      protected void setTaskAttemptId(TaskAttemptID taskId)
      Sets task id.
      Parameters:
      taskId -

    • setTaskStatus

      protected void setTaskStatus(TaskCompletionEvent.Status status)
      Set task status.
      Parameters:
      status -

    • setTaskTrackerHttp

      protected void setTaskTrackerHttp(String taskTrackerHttp)
      Set task tracker http location.
      Parameters:
      taskTrackerHttp -

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • isMapTask

      public boolean isMapTask()

    • idWithinJob

      public int idWithinJob()

    • write

      public void write(DataOutput out) throws IOException
      Description copied from interface: Writable
      Serialize the fields of this object to out.
      Specified by:
      write in interface Writable
      Parameters:
      out - DataOuput to serialize this object into.
      Throws:
      IOException - any other problem for write.

    • readFields

      public void readFields(DataInput in) throws IOException
      Description copied from interface: Writable
      Deserialize the fields of this object from in.

      For efficiency, implementations should attempt to re-use storage in the existing object where possible.

      Specified by:
      readFields in interface Writable
      Parameters:
      in - DataInput to deseriablize this object from.
      Throws:
      IOException - any other problem for readFields.