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

Interface Task

All Superinterfaces:
org.apache.hadoop.io.Writable
All Known Implementing Classes:
AbstractTask, CompositeTask, DieTask, NullTask, SimpleTask, TeardownTask
public interface Task extends org.apache.hadoop.io.Writable
Define Task Interface.

  • Method Details

    • getTaskId

      TaskId getTaskId()
      Get TaskId of a Task.
      Returns:
      value of TaskId

    • getEnvironment

      Map<String,String> getEnvironment()
      Get Environment of Task.
      Returns:
      map of environment

    • getTaskCmd

      String getTaskCmd()
      Get Task cmd.
      Returns:
      value of Task cmd such "sleep 1"

    • getTaskType

      TaskType getTaskType()
      Get Task type such as Simple, Composite.
      Returns:
      value of TaskType

    • setTaskId

      void setTaskId(TaskId taskId)
      Set TaskId.
      Parameters:
      taskId - : Task identifier

    • setEnvironment

      void setEnvironment(Map<String,String> environment)
      Set Task environment such as {"HOME":"/user/A"}.
      Parameters:
      environment - : Map of environment variables

    • setTaskCmd

      void setTaskCmd(String taskCMD)
      Set Task command.
      Parameters:
      taskCMD - : Task command to be executed

    • getTimeout

      long getTimeout()
      Get Task Timeout in seconds.
      Returns:
      value of TaskTimeout

    • setTimeout

      void setTimeout(long timeout)
      Set Task Timeout.
      Parameters:
      timeout - : value of Task Timeout