Package org.apache.wayang.spark.monitoring.interfaces

Interface Task

All Superinterfaces:
Serializable, SerializableObject
All Known Implementing Classes:
TaskEnd, TaskGettingResult, TaskStart
public interface Task extends SerializableObject
The Task interface represents a task in a distributed computing or data processing system.

This interface extends the SerializableObject interface and defines the methods that should be implemented by a task in order to properly function in such a system.

The Task interface provides methods for setting and getting various properties of a task, including its ID, status, and execution metrics.

The Task interface also includes an enum for representing the status of a task while it is running.

Author:
[Adeel Aslam]

  • Method Details

    • setEventame

      void setEventame(String name)
      Sets the name of the event associated with this task.
      Parameters:
      name - the name of the event

    • getEventName

      String getEventName()
      Gets the name of the event associated with this task.
      Returns:
      the name of the event

    • setID

      void setID(String id)
      Sets the ID of this task.
      Parameters:
      id - the task ID

    • getID

      String getID()
      Gets the ID of this task.
      Returns:
      the task ID

    • setHostIP

      void setHostIP(String Ip)
      Sets the IP address of the host machine executing this task.
      Parameters:
      Ip - the IP address of the host machine

    • getHostIP

      String getHostIP()
      Gets the IP address of the host machine executing this task.
      Returns:
      the IP address of the host machine

    • setTaskID

      void setTaskID(long taskId)
      Sets the ID of this task.
      Parameters:
      taskId - the ID of this task

    • setStageID

      void setStageID(int id)
      Sets the ID of the stage to which this task belongs.
      Parameters:
      id - the ID of the stage to which this task belongs

    • getStageID

      int getStageID()
      Returns the ID of the stage to which this task belongs.
      Returns:
      the ID of the stage to which this task belongs

    • getTaskID

      long getTaskID()
      Returns the ID of this task.
      Returns:
      the ID of this task

    • setStringExecutorID

      void setStringExecutorID(String executorID)
      Sets the ID of the executor assigned to this task.
      Parameters:
      executorID - the ID of the executor assigned to this task

    • getExecutorID

      String getExecutorID()
      Returns the ID of the executor assigned to this task.
      Returns:
      the ID of the executor assigned to this task

    • setTaskStatus

      void setTaskStatus(String status)
      Sets the status of this task.
      Parameters:
      status - the status of this task

    • getTaskStatus

      String getTaskStatus()
      Returns the status of this task.
      Returns:
      the status of this task

    • setIndex

      void setIndex(int index)
      Sets the index of this task.
      Parameters:
      index - the index of this task

    • getIndex

      int getIndex()
      Returns the index of this task.
      Returns:
      the index of this task

    • setPartition

      void setPartition(int partition)
      Sets the partition of this task.
      Parameters:
      partition - the partition of this task

    • getPartition

      int getPartition()
      Returns the partition of this task.
      Returns:
      the partition of this task

    • setLaunchTime

      void setLaunchTime(long time)
      Sets the launch time of this task.
      Parameters:
      time - the launch time of this task

    • getLaunchTime

      long getLaunchTime()
      Returns the launch time of this task.
      Returns:
      the launch time of this task

    • setFinishTime

      void setFinishTime(long time)
      Sets the finish time of this task.
      Parameters:
      time - the finish time of this task

    • getFinishTime

      long getFinishTime()
      Returns the finish time of this task.
      Returns:
      the finish time of this task

    • setGettingTime

      void setGettingTime(long time)
      Sets the getting time of this task.
      Parameters:
      time - the getting time of this task

    • getGettingTime

      long getGettingTime()
      Returns the getting time of this task.
      Returns:
      the getting time of this task

    • setDurationTime

      void setDurationTime(long time)
      Sets the duration time of this task.
      Parameters:
      time - the duration time of this task

    • getDurationTime

      long getDurationTime()
      Returns the duration time of this task.
      Returns:
      the duration time of this task

    • setTaskStatus

      void setTaskStatus(boolean status)
      Sets the status of this task.
      Parameters:
      status - the status of this task

    • getTaskSatus

      boolean getTaskSatus()
      Returns the status of this task.
      Returns:
      the status of this task

    • setTaskStatusForRunning

      void setTaskStatusForRunning(Task.TaskStatusForRunning taskStatusForRunning)
      Sets the task status for running.
      Parameters:
      taskStatusForRunning - the Task.TaskStatusForRunning status to be set for the task

    • getTaskStatusForRunning

      Task.TaskStatusForRunning getTaskStatusForRunning()
      Returns the current task status for running.
      Returns:
      the Task.TaskStatusForRunning status of the task

    • getTaskMetric

      TaskMetric getTaskMetric()
      Returns the TaskMetric associated with this task.
      Returns:
      the TaskMetric of the task

    • setTaskMetric

      void setTaskMetric(TaskMetric taskMetric)
      Sets the TaskMetric associated with this task.
      Parameters:
      taskMetric - the TaskMetric to be set for the task