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

Class AbstractTask

java.lang.Object
org.apache.hadoop.applications.mawo.server.common.AbstractTask
All Implemented Interfaces:
Task, org.apache.hadoop.io.Writable
Direct Known Subclasses:
CompositeTask, DieTask, NullTask, SimpleTask
public abstract class AbstractTask extends Object implements Task
Abstract class for MaWo Task.

  • Constructor Details

    • AbstractTask

      public AbstractTask()
      AbstractTask constructor.

    • AbstractTask

      public AbstractTask(TaskId taskId, Map<String,String> localenvironment, String taskCMD, long localtimeout)
      AbstrackTask constructor.
      Parameters:
      taskId - : Task identifier
      localenvironment - : Task environment vars
      taskCMD - : Cmd to run
      localtimeout - : Task timeout in seconds

  • Method Details

    • getEnvironment

      public final Map<String,String> getEnvironment()
      Get environment for a Task.
      Specified by:
      getEnvironment in interface Task
      Returns:
      environment of a Task

    • setEnvironment

      public final void setEnvironment(Map<String,String> localenvironment)
      Set environment for a Task.
      Specified by:
      setEnvironment in interface Task
      Parameters:
      localenvironment - : Map of environment vars

    • getTaskCmd

      public final String getTaskCmd()
      Get TaskCmd for a Task.
      Specified by:
      getTaskCmd in interface Task
      Returns:
      TaskCMD: Its a task command line such as sleep 10

    • setTaskCmd

      public final void setTaskCmd(String taskCMD)
      Set TaskCmd for a Task.
      Specified by:
      setTaskCmd in interface Task
      Parameters:
      taskCMD - : Task command line

    • getTaskId

      public final TaskId getTaskId()
      Get TaskId for a Task.
      Specified by:
      getTaskId in interface Task
      Returns:
      TaskID: Task command line

    • setTaskId

      public final void setTaskId(TaskId taskId)
      Set Task Id.
      Specified by:
      setTaskId in interface Task
      Parameters:
      taskId - : Task Identifier

    • getTaskType

      public final TaskType getTaskType()
      Get TaskType for a Task.
      Specified by:
      getTaskType in interface Task
      Returns:
      TaskType: Type of Task

    • setTaskType

      public final void setTaskType(TaskType type)
      Set TaskType for a Task.
      Parameters:
      type - Simple or Composite Task

    • getTimeout

      public final long getTimeout()
      Get Timeout for a Task.
      Specified by:
      getTimeout in interface Task
      Returns:
      timeout in seconds

    • setTimeout

      public final void setTimeout(long taskTimeout)
      Set Task Timeout in seconds.
      Specified by:
      setTimeout in interface Task
      Parameters:
      taskTimeout - : Timeout in seconds

    • write

      public final void write(DataOutput out) throws IOException
      Write Task.
      Specified by:
      write in interface org.apache.hadoop.io.Writable
      Parameters:
      out - : dataoutout object.
      Throws:
      IOException - : Throws IO exception if any error occurs.

    • readFields

      public final void readFields(DataInput in) throws IOException
      Read Fields from file.
      Specified by:
      readFields in interface org.apache.hadoop.io.Writable
      Parameters:
      in - : datainput object.
      Throws:
      IOException - : Throws IOException in case of error.

    • toString

      public final String toString()
      ToString.
      Overrides:
      toString in class Object
      Returns:
      String representation of Task