Package org.apache.wayang.spark.monitoring.metrics

Class TaskStart

java.lang.Object
org.apache.wayang.spark.monitoring.metrics.TaskStart
All Implemented Interfaces:
Serializable, SerializableObject, Task
public class TaskStart extends Object implements Task, SerializableObject
Represents the start status of a task execution.

Implementing the Task interface, this class provides methods to set and get the attributes of a task, such as its ID, host IP, launch and finish times, and status. It also implements the SerializableObject interface to allow serialization of the class.

The class also includes a TaskMetric object to store metrics related to the task, and a Task.TaskStatusForRunning object to provide information about the task's status during execution.

Author:
[Adeel Aslam]
See Also:

  • Constructor Details

    • TaskStart

      public TaskStart()

  • Method Details

    • setEventame

      public void setEventame(String name)
      Description copied from interface: Task
      Sets the name of the event associated with this task.
      Specified by:
      setEventame in interface Task
      Parameters:
      name - the name of the event

    • getEventName

      public String getEventName()
      Description copied from interface: Task
      Gets the name of the event associated with this task.
      Specified by:
      getEventName in interface Task
      Returns:
      the name of the event

    • setID

      public void setID(String id)
      Description copied from interface: Task
      Sets the ID of this task.
      Specified by:
      setID in interface Task
      Parameters:
      id - the task ID

    • getID

      public String getID()
      Description copied from interface: Task
      Gets the ID of this task.
      Specified by:
      getID in interface Task
      Returns:
      the task ID

    • setHostIP

      public void setHostIP(String Ip)
      Description copied from interface: Task
      Sets the IP address of the host machine executing this task.
      Specified by:
      setHostIP in interface Task
      Parameters:
      Ip - the IP address of the host machine

    • getHostIP

      public String getHostIP()
      Description copied from interface: Task
      Gets the IP address of the host machine executing this task.
      Specified by:
      getHostIP in interface Task
      Returns:
      the IP address of the host machine

    • setTaskID

      public void setTaskID(long taskId)
      Description copied from interface: Task
      Sets the ID of this task.
      Specified by:
      setTaskID in interface Task
      Parameters:
      taskId - the ID of this task

    • setStageID

      public void setStageID(int id)
      Description copied from interface: Task
      Sets the ID of the stage to which this task belongs.
      Specified by:
      setStageID in interface Task
      Parameters:
      id - the ID of the stage to which this task belongs

    • getStageID

      public int getStageID()
      Description copied from interface: Task
      Returns the ID of the stage to which this task belongs.
      Specified by:
      getStageID in interface Task
      Returns:
      the ID of the stage to which this task belongs

    • getTaskID

      public long getTaskID()
      Description copied from interface: Task
      Returns the ID of this task.
      Specified by:
      getTaskID in interface Task
      Returns:
      the ID of this task

    • setStringExecutorID

      public void setStringExecutorID(String executorID)
      Description copied from interface: Task
      Sets the ID of the executor assigned to this task.
      Specified by:
      setStringExecutorID in interface Task
      Parameters:
      executorID - the ID of the executor assigned to this task

    • getExecutorID

      public String getExecutorID()
      Description copied from interface: Task
      Returns the ID of the executor assigned to this task.
      Specified by:
      getExecutorID in interface Task
      Returns:
      the ID of the executor assigned to this task

    • setTaskStatus

      public void setTaskStatus(String status)
      Description copied from interface: Task
      Sets the status of this task.
      Specified by:
      setTaskStatus in interface Task
      Parameters:
      status - the status of this task

    • getTaskStatus

      public String getTaskStatus()
      Description copied from interface: Task
      Returns the status of this task.
      Specified by:
      getTaskStatus in interface Task
      Returns:
      the status of this task

    • setIndex

      public void setIndex(int index)
      Description copied from interface: Task
      Sets the index of this task.
      Specified by:
      setIndex in interface Task
      Parameters:
      index - the index of this task

    • getIndex

      public int getIndex()
      Description copied from interface: Task
      Returns the index of this task.
      Specified by:
      getIndex in interface Task
      Returns:
      the index of this task

    • setPartition

      public void setPartition(int partition)
      Description copied from interface: Task
      Sets the partition of this task.
      Specified by:
      setPartition in interface Task
      Parameters:
      partition - the partition of this task

    • getPartition

      public int getPartition()
      Description copied from interface: Task
      Returns the partition of this task.
      Specified by:
      getPartition in interface Task
      Returns:
      the partition of this task

    • setLaunchTime

      public void setLaunchTime(long time)
      Description copied from interface: Task
      Sets the launch time of this task.
      Specified by:
      setLaunchTime in interface Task
      Parameters:
      time - the launch time of this task

    • getLaunchTime

      public long getLaunchTime()
      Description copied from interface: Task
      Returns the launch time of this task.
      Specified by:
      getLaunchTime in interface Task
      Returns:
      the launch time of this task

    • setFinishTime

      public void setFinishTime(long time)
      Description copied from interface: Task
      Sets the finish time of this task.
      Specified by:
      setFinishTime in interface Task
      Parameters:
      time - the finish time of this task

    • getFinishTime

      public long getFinishTime()
      Description copied from interface: Task
      Returns the finish time of this task.
      Specified by:
      getFinishTime in interface Task
      Returns:
      the finish time of this task

    • setGettingTime

      public void setGettingTime(long time)
      Description copied from interface: Task
      Sets the getting time of this task.
      Specified by:
      setGettingTime in interface Task
      Parameters:
      time - the getting time of this task

    • getGettingTime

      public long getGettingTime()
      Description copied from interface: Task
      Returns the getting time of this task.
      Specified by:
      getGettingTime in interface Task
      Returns:
      the getting time of this task

    • setDurationTime

      public void setDurationTime(long time)
      Description copied from interface: Task
      Sets the duration time of this task.
      Specified by:
      setDurationTime in interface Task
      Parameters:
      time - the duration time of this task

    • getDurationTime

      public long getDurationTime()
      Description copied from interface: Task
      Returns the duration time of this task.
      Specified by:
      getDurationTime in interface Task
      Returns:
      the duration time of this task

    • setTaskStatus

      public void setTaskStatus(boolean status)
      Description copied from interface: Task
      Sets the status of this task.
      Specified by:
      setTaskStatus in interface Task
      Parameters:
      status - the status of this task

    • getTaskSatus

      public boolean getTaskSatus()
      Description copied from interface: Task
      Returns the status of this task.
      Specified by:
      getTaskSatus in interface Task
      Returns:
      the status of this task

    • setTaskStatusForRunning

      public void setTaskStatusForRunning(Task.TaskStatusForRunning taskStatusForRunning)
      Description copied from interface: Task
      Sets the task status for running.
      Specified by:
      setTaskStatusForRunning in interface Task
      Parameters:
      taskStatusForRunning - the Task.TaskStatusForRunning status to be set for the task

    • getTaskStatusForRunning

      public Task.TaskStatusForRunning getTaskStatusForRunning()
      Description copied from interface: Task
      Returns the current task status for running.
      Specified by:
      getTaskStatusForRunning in interface Task
      Returns:
      the Task.TaskStatusForRunning status of the task

    • getTaskMetric

      public TaskMetric getTaskMetric()
      Description copied from interface: Task
      Returns the TaskMetric associated with this task.
      Specified by:
      getTaskMetric in interface Task
      Returns:
      the TaskMetric of the task

    • setTaskMetric

      public void setTaskMetric(TaskMetric taskMetric)
      Description copied from interface: Task
      Sets the TaskMetric associated with this task.
      Specified by:
      setTaskMetric in interface Task
      Parameters:
      taskMetric - the TaskMetric to be set for the task