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

Interface WorkAssignmentProtocol

public interface WorkAssignmentProtocol
Define work assignment protocol.

  • Method Details

    • getNewWorkerId

      org.apache.hadoop.io.Text getNewWorkerId()
      Get next workerId to which new task will be assigned.
      Returns:
      return workerId text

    • registerWorker

      Task registerWorker(WorkerId workerId)
      Register Worker. When worker will be launched first, it needs to be registered with Master.
      Parameters:
      workerId - : Worker Id
      Returns:
      Task instance

    • deRegisterWorker

      void deRegisterWorker(WorkerId workerId)
      De Register worker. When worker is de-registered, no new task will be assigned to this worker.
      Parameters:
      workerId - : Worker identifier

    • sendHeartbeat

      Task sendHeartbeat(WorkerId workerId, TaskStatus[] taskStatusList)
      Worker sends heartbeat to Master.
      Parameters:
      workerId - : Worker Id
      taskStatusList - : TaskStatus list of all tasks assigned to worker.
      Returns:
      Task instance

    • addTask

      void addTask(Task task)
      Add Task to the list.
      Parameters:
      task - : Task object