Package org.apache.hadoop.applications.mawo.server.common

Class TaskStatus

java.lang.Object
org.apache.hadoop.applications.mawo.server.common.TaskStatus
All Implemented Interfaces:
Cloneable, org.apache.hadoop.io.Writable
public class TaskStatus extends Object implements org.apache.hadoop.io.Writable, Cloneable
Defines TaskStatus for MaWo app.

  • Constructor Details

    • TaskStatus

      public TaskStatus()
      Task status constructor.

    • TaskStatus

      public TaskStatus(WorkerId localworkerId, TaskId localtaskId, String localtaskCMD, String localtaskType)
      Task status constructor with workerId, TaskId, TaskCmd, TaskType.
      Parameters:
      localworkerId - : Worker ID
      localtaskId - : Task ID
      localtaskCMD - : Task command line
      localtaskType - : Type of Task

    • TaskStatus

      public TaskStatus(WorkerId localworkerId, TaskId localtaskId, TaskStatus.State localrunState, String localtaskCMD, String localtaskType)
      Task status constructor with workerId, TaskId, TaskCmd, TaskType and Run State.
      Parameters:
      localworkerId - : Worker Id
      localtaskId - : Task Id
      localrunState - : Task run State
      localtaskCMD - : Task cmd
      localtaskType - : Task type

  • Method Details

    • getRunState

      public final TaskStatus.State getRunState()
      Get status of a Task.
      Returns:
      Status of a Task

    • setRunState

      public final void setRunState(TaskStatus.State localrunState)
      Update status of a Task.
      Parameters:
      localrunState - : Status of a Task

    • setExitCode

      public final void setExitCode(int localexitCode)
      Set exitcode of a Task.
      Parameters:
      localexitCode - : Exitcode of a Task

    • getExitCode

      public final int getExitCode()
      Get exitcode of a Task.
      Returns:
      exitCode of Task

    • setTaskCMD

      public final void setTaskCMD(String localcmd)
      Set Task cmd of a Task.
      Parameters:
      localcmd - : command line which need to be executed

    • getTaskCMD

      public final String getTaskCMD()
      Get Task cmd of a Task.
      Returns:
      TaskCmd : command line which need to be executed

    • setTaskType

      public final void setTaskType(String localtaskType)
      Set Task Type.
      Parameters:
      localtaskType - : TaskType such as SimpleTask, NullTask

    • getTaskType

      public final String getTaskType()
      Get Task Type.
      Returns:
      TaskType : TaskType such as SimpleTask, NullTask

    • getTaskId

      public final TaskId getTaskId()
      Get Task Id.
      Returns:
      TaskId : Task identifier

    • setTaskId

      public final void setTaskId(TaskId localtaskId)
      Set TaskId.
      Parameters:
      localtaskId - : Task identifier

    • setTaskState

      public final void setTaskState(TaskId localtaskId, TaskStatus.State localrunState)
      Set staus of a Task.
      Parameters:
      localtaskId - : TaskId of a task
      localrunState - : Run state of a task

    • getTaskState

      public final TaskStatus.State getTaskState(TaskId localtaskId)
      Get Task status of a Task.
      Parameters:
      localtaskId - : Task Id
      Returns:
      TaskStatus for valid Task otherwise Null

    • getStartTime

      public final long getStartTime()
      Get starttime of a Task.
      Returns:
      StartTime of Task

    • setStartTime

      public final void setStartTime()
      Set current time as start time of a Task.

    • getEndTime

      public final long getEndTime()
      Get task end time.
      Returns:
      End time of task.

    • setEndTime

      public final void setEndTime()
      Set task end time to current time.

    • write

      public final void write(DataOutput dataOutput) throws IOException
      Specified by:
      write in interface org.apache.hadoop.io.Writable
      Throws:
      IOException

    • readFields

      public final void readFields(DataInput dataInput) throws IOException
      Specified by:
      readFields in interface org.apache.hadoop.io.Writable
      Throws:
      IOException

    • getWorkerId

      public final WorkerId getWorkerId()
      Get workerId.
      Returns:
      workerId : Worker identifier

    • setWorkerId

      public final void setWorkerId(WorkerId localworkerId)
      Set WorkerId.
      Parameters:
      localworkerId - : Worker identifier

    • equals

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

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • clone

      protected Object clone() throws CloneNotSupportedException
      Overrides:
      clone in class Object
      Throws:
      CloneNotSupportedException