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

Class TaskMetric

java.lang.Object
org.apache.wayang.spark.monitoring.metrics.TaskMetric
All Implemented Interfaces:
Serializable, SerializableObject, TaskMetric
public class TaskMetric extends Object implements TaskMetric, SerializableObject
This class represents the metrics for a task in the Apache Wayang monitoring system. It implements the TaskMetric interface and SerializableObject interface to allow for serialization.
See Also:

  • Constructor Details

    • TaskMetric

      public TaskMetric()

  • Method Details

    • getExecutorCPUTime

      public long getExecutorCPUTime()

    • setExecutorCPUTime

      public void setExecutorCPUTime(long executorCPUTime)

    • setBytesRead

      public void setBytesRead(long bytesRead)
      Description copied from interface: TaskMetric
      Sets the number of bytes read by the task.
      Specified by:
      setBytesRead in interface TaskMetric
      Parameters:
      bytesRead - the number of bytes read

    • getByteRead

      public long getByteRead()
      Description copied from interface: TaskMetric
      Gets the number of bytes read by the task.
      Specified by:
      getByteRead in interface TaskMetric
      Returns:
      the number of bytes read

    • setExecutorDeserializeCpuTime

      public void setExecutorDeserializeCpuTime(long executorDeserializeCpuTime)
      Description copied from interface: TaskMetric
      Sets the CPU time used for deserializing the task executor.
      Specified by:
      setExecutorDeserializeCpuTime in interface TaskMetric
      Parameters:
      executorDeserializeCpuTime - the CPU time used for deserializing the executor

    • getExecutorDeserializeCpuTime

      public long getExecutorDeserializeCpuTime()
      Description copied from interface: TaskMetric
      Gets the CPU time used for deserializing the task executor.
      Specified by:
      getExecutorDeserializeCpuTime in interface TaskMetric
      Returns:
      the CPU time used for deserializing the executor

    • setExecutorDeserializeTime

      public void setExecutorDeserializeTime(long executorDeserializeTime)
      Description copied from interface: TaskMetric
      Sets the time taken to deserialize the task executor.
      Specified by:
      setExecutorDeserializeTime in interface TaskMetric
      Parameters:
      executorDeserializeTime - the time taken to deserialize the executor

    • getExecutorDeserializeTime

      public long getExecutorDeserializeTime()
      Description copied from interface: TaskMetric
      Gets the time taken to deserialize the task executor.
      Specified by:
      getExecutorDeserializeTime in interface TaskMetric
      Returns:
      the time taken to deserialize the executor

    • setDiskBytesSpilled

      public void setDiskBytesSpilled(long DiskByteSpilled)
      Description copied from interface: TaskMetric
      Sets the number of bytes spilled to disk by the task.
      Specified by:
      setDiskBytesSpilled in interface TaskMetric
      Parameters:
      DiskByteSpilled - the number of bytes spilled to disk

    • getDiskBytesSpilled

      public long getDiskBytesSpilled()
      Description copied from interface: TaskMetric
      Gets the number of bytes spilled to disk by the task.
      Specified by:
      getDiskBytesSpilled in interface TaskMetric
      Returns:
      the number of bytes spilled to disk

    • setExecutorRunTime

      public void setExecutorRunTime(long time)
      Description copied from interface: TaskMetric
      Sets the total time taken by the task executor to run.
      Specified by:
      setExecutorRunTime in interface TaskMetric
      Parameters:
      time - the time taken by the executor to run

    • getexecutorRunTime

      public long getexecutorRunTime()
      Description copied from interface: TaskMetric
      Gets the total time taken by the task executor to run.
      Specified by:
      getexecutorRunTime in interface TaskMetric
      Returns:
      the time taken by the executor to run

    • setjvmGCTime

      public void setjvmGCTime(long time)
      Description copied from interface: TaskMetric
      Sets the amount of time spent by the JVM on garbage collection.
      Specified by:
      setjvmGCTime in interface TaskMetric
      Parameters:
      time - the amount of time spent on garbage collection

    • getJVMGCTime

      public long getJVMGCTime()
      Description copied from interface: TaskMetric
      Gets the amount of time spent by the JVM on garbage collection.
      Specified by:
      getJVMGCTime in interface TaskMetric
      Returns:
      the amount of time spent on garbage collection

    • setPeakExecutionMemory

      public void setPeakExecutionMemory(long peakExecutionMemory)
      Description copied from interface: TaskMetric
      Sets the peak execution memory used by the task executor.
      Specified by:
      setPeakExecutionMemory in interface TaskMetric
      Parameters:
      peakExecutionMemory - the peak execution memory used by the executor

    • getPeakExecutionMemory

      public long getPeakExecutionMemory()
      Description copied from interface: TaskMetric
      Gets the peak execution memory used by the task executor.
      Specified by:
      getPeakExecutionMemory in interface TaskMetric
      Returns:
      the peak execution memory used by the executor

    • setResultSize

      public void setResultSize(long resultSize)
      Description copied from interface: TaskMetric
      Sets the size of the result produced by the task.
      Specified by:
      setResultSize in interface TaskMetric
      Parameters:
      resultSize - the size of the result produced

    • getResultSize

      public long getResultSize()
      Description copied from interface: TaskMetric
      Gets the size of the result produced by the task.
      Specified by:
      getResultSize in interface TaskMetric
      Returns:
      the size of the result produced

    • setResultSerializationTime

      public void setResultSerializationTime(long resultSerializationTime)
      Description copied from interface: TaskMetric
      Sets the time taken to serialize the result of the task.
      Specified by:
      setResultSerializationTime in interface TaskMetric
      Parameters:
      resultSerializationTime - the time taken to serialize the result

    • getResultSerializationTime

      public long getResultSerializationTime()
      Description copied from interface: TaskMetric
      Returns the time taken to serialize the result of the task.
      Specified by:
      getResultSerializationTime in interface TaskMetric
      Returns:
      the time taken to serialize the result

    • setRecordsWritten

      public void setRecordsWritten(long recordsWritten)
      Description copied from interface: TaskMetric
      Sets the number of records written by the task.
      Specified by:
      setRecordsWritten in interface TaskMetric
      Parameters:
      recordsWritten - the number of records written

    • getRecordsWrittern

      public long getRecordsWrittern()
      Description copied from interface: TaskMetric
      Returns the number of records written by the task.
      Specified by:
      getRecordsWrittern in interface TaskMetric
      Returns:
      the number of records written

    • setBytesWritten

      public void setBytesWritten(long bytesWritten)
      Description copied from interface: TaskMetric
      Sets the number of bytes written by the task.
      Specified by:
      setBytesWritten in interface TaskMetric
      Parameters:
      bytesWritten - the number of bytes written

    • getBytesWrittern

      public long getBytesWrittern()
      Description copied from interface: TaskMetric
      Returns the number of bytes written by the task.
      Specified by:
      getBytesWrittern in interface TaskMetric
      Returns:
      the number of bytes written