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

Class ExecutorAdded

java.lang.Object
org.apache.wayang.spark.monitoring.metrics.ExecutorAdded
All Implemented Interfaces:
Serializable, Executor, SerializableObject
public class ExecutorAdded extends Object implements Executor, SerializableObject
The ExecutorAdded class represents an executor added event in a distributed computing system. It implements the Executor interface and the SerializableObject interface. This class contains information about the executor that was added, such as its stage ID, executor ID, stage attempt, time, executor host, total cores, and reason of removal. This class provides getters and setters for all of the above properties, and implements the methods defined in the Executor interface.
See Also:

  • Constructor Details

    • ExecutorAdded

      public ExecutorAdded()

  • Method Details

    • 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.

    • 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.

    • 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.