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

Class ExecutorRemoved

java.lang.Object
org.apache.wayang.spark.monitoring.metrics.ExecutorRemoved
All Implemented Interfaces:
Serializable, Executor, SerializableObject
public class ExecutorRemoved extends Object implements Executor, SerializableObject
An event class representing the removal of an executor. Implements the Executor interface and SerializableObject interface.
See Also:

  • Constructor Details

    • ExecutorRemoved

      public ExecutorRemoved()

  • Method Details

    • getReasonOfRemoval

      public String getReasonOfRemoval()
      Description copied from interface: Executor
      Returns the reason for which this executor was removed from the cluster.
      Specified by:
      getReasonOfRemoval in interface Executor
      Returns:
      The reason for removal.

    • setReasonOfRemoval

      public void setReasonOfRemoval(String reasonOfRemoval)
      Description copied from interface: Executor
      Sets the reason for which this executor was removed from the cluster.
      Specified by:
      setReasonOfRemoval in interface Executor
      Parameters:
      reasonOfRemoval - The reason for removal.

    • setEventame

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

    • getEventName

      public String getEventName()
      Description copied from interface: Executor
      Returns the name of the event associated with this executor.
      Specified by:
      getEventName in interface Executor
      Returns:
      The name of the event.

    • setStageID

      public void setStageID(int id)
      Description copied from interface: Executor
      Sets the ID of the stage the executor is running.
      Specified by:
      setStageID in interface Executor
      Parameters:
      id - The ID of the stage.

    • getStageID

      public int getStageID()
      Description copied from interface: Executor
      Returns the ID of the stage the executor is running.
      Specified by:
      getStageID in interface Executor
      Returns:
      The ID of the stage.

    • setExecutorID

      public void setExecutorID(String id)
      Description copied from interface: Executor
      Sets the ID of this executor.
      Specified by:
      setExecutorID in interface Executor
      Parameters:
      id - The ID of the executor.

    • getExecutorID

      public String getExecutorID()
      Description copied from interface: Executor
      Returns the ID of this executor.
      Specified by:
      getExecutorID in interface Executor
      Returns:
      The ID of the executor.

    • stageAttempt

      public void stageAttempt(int id)
      Description copied from interface: Executor
      Sets the attempt ID of the stage.
      Specified by:
      stageAttempt in interface Executor
      Parameters:
      id - The attempt ID of the stage.

    • getStageAttempt

      public int getStageAttempt()
      Description copied from interface: Executor
      Returns the attempt ID of the stage.
      Specified by:
      getStageAttempt in interface Executor
      Returns:
      The attempt ID of the stage.

    • executorTime

      public void executorTime(long Time)
      Description copied from interface: Executor
      Sets the time at which this executor started.
      Specified by:
      executorTime in interface Executor
      Parameters:
      Time - The start time of the executor.

    • getExecutorTime

      public long getExecutorTime()
      Description copied from interface: Executor
      Returns the time at which this executor started.
      Specified by:
      getExecutorTime in interface Executor
      Returns:
      The start time of the executor.

    • setExecutorHost

      public void setExecutorHost(String host)
      Description copied from interface: Executor
      Sets the host where this executor is running.
      Specified by:
      setExecutorHost in interface Executor
      Parameters:
      host - The host where the executor is running.

    • getExecutorHost

      public String getExecutorHost()
      Description copied from interface: Executor
      Returns the host where this executor is running.
      Specified by:
      getExecutorHost in interface Executor
      Returns:
      The host where the executor is running.

    • setTotalCores

      public void setTotalCores(int cores)
      Description copied from interface: Executor
      Sets the total number of cores available to this executor.
      Specified by:
      setTotalCores in interface Executor
      Parameters:
      cores - The total number of cores.

    • getTotalCores

      public int getTotalCores()
      Description copied from interface: Executor
      Returns the total number of cores available to this executor.
      Specified by:
      getTotalCores in interface Executor
      Returns:
      The total number of cores.

    • setResourceInfo

      public void setResourceInfo(int resourceInfoId)
      Description copied from interface: Executor
      Sets the resource information of this executor.
      Specified by:
      setResourceInfo in interface Executor
      Parameters:
      resourceInfoId - The resource information of the executor.

    • getResourceInfo

      public int getResourceInfo()
      Description copied from interface: Executor
      Returns the resource information of this executor.
      Specified by:
      getResourceInfo in interface Executor
      Returns:
      The resource information of the executor.