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

Class TaskGettingResult

java.lang.Object

org.apache.wayang.spark.monitoring.metrics.TaskGettingResult

All Implemented Interfaces:

java.io.Serializable, SerializableObject, Task

public class TaskGettingResult
extends java.lang.Object
implements Task, SerializableObject

Represents the getting results 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:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.wayang.spark.monitoring.interfaces.Task

Task.TaskStatusForRunning

Constructor Summary

Constructors

Constructor	Description
TaskGettingResult()

Method Summary

Modifier and Type	Method	Description
long	getDurationTime()	Returns the duration time of this task.
java.lang.String	getEventName()	Gets the name of the event associated with this task.
java.lang.String	getExecutorID()	Returns the ID of the executor assigned to this task.
long	getFinishTime()	Returns the finish time of this task.
long	getGettingTime()	Returns the getting time of this task.
java.lang.String	getHostIP()	Gets the IP address of the host machine executing this task.
java.lang.String	getID()	Gets the ID of this task.
int	getIndex()	Returns the index of this task.
long	getLaunchTime()	Returns the launch time of this task.
int	getPartition()	Returns the partition of this task.
int	getStageID()	Returns the ID of the stage to which this task belongs.
long	getTaskID()	Returns the ID of this task.
TaskMetric	getTaskMetric()	Returns the TaskMetric associated with this task.
boolean	getTaskSatus()	Returns the status of this task.
java.lang.String	getTaskStatus()	Returns the status of this task.
Task.TaskStatusForRunning	getTaskStatusForRunning()	Returns the current task status for running.
void	setDurationTime(long time)	Sets the duration time of this task.
void	setEventame(java.lang.String name)	Sets the name of the event associated with this task.
void	setFinishTime(long time)	Sets the finish time of this task.
void	setGettingTime(long time)	Sets the getting time of this task.
void	setHostIP(java.lang.String Ip)	Sets the IP address of the host machine executing this task.
void	setID(java.lang.String id)	Sets the ID of this task.
void	setIndex(int index)	Sets the index of this task.
void	setLaunchTime(long time)	Sets the launch time of this task.
void	setPartition(int partition)	Sets the partition of this task.
void	setStageID(int id)	Sets the ID of the stage to which this task belongs.
void	setStringExecutorID(java.lang.String executorID)	Sets the ID of the executor assigned to this task.
void	setTaskID(long taskId)	Sets the ID of this task.
void	setTaskMetric(TaskMetric taskMetric)	Sets the TaskMetric associated with this task.
void	setTaskStatus(boolean status)	Sets the status of this task.
void	setTaskStatus(java.lang.String status)	Sets the status of this task.
void	setTaskStatusForRunning(Task.TaskStatusForRunning taskStatusForRunning)	Sets the task status for running.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskGettingResult

public TaskGettingResult()

Method Detail

setEventame

public void setEventame(java.lang.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 java.lang.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(java.lang.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 java.lang.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(java.lang.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 java.lang.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(java.lang.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 java.lang.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(java.lang.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 java.lang.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