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

Class ExecutorRemoved

    • Constructor Summary

      Constructors 
      Constructor Description
      ExecutorRemoved()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void executorTime​(long Time)
      Sets the time at which this executor started.
      java.lang.String getEventName()
      Returns the name of the event associated with this executor.
      java.lang.String getExecutorHost()
      Returns the host where this executor is running.
      java.lang.String getExecutorID()
      Returns the ID of this executor.
      long getExecutorTime()
      Returns the time at which this executor started.
      java.lang.String getReasonOfRemoval()
      Returns the reason for which this executor was removed from the cluster.
      int getResourceInfo()
      Returns the resource information of this executor.
      int getStageAttempt()
      Returns the attempt ID of the stage.
      int getStageID()
      Returns the ID of the stage the executor is running.
      int getTotalCores()
      Returns the total number of cores available to this executor.
      void setEventame​(java.lang.String name)
      Sets the name of the event associated with this executor.
      void setExecutorHost​(java.lang.String host)
      Sets the host where this executor is running.
      void setExecutorID​(java.lang.String id)
      Sets the ID of this executor.
      void setReasonOfRemoval​(java.lang.String reasonOfRemoval)
      Sets the reason for which this executor was removed from the cluster.
      void setResourceInfo​(int resourceInfoId)
      Sets the resource information of this executor.
      void setStageID​(int id)
      Sets the ID of the stage the executor is running.
      void setTotalCores​(int cores)
      Sets the total number of cores available to this executor.
      void stageAttempt​(int id)
      Sets the attempt ID of the stage.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • ExecutorRemoved

        public ExecutorRemoved()

    • Method Detail

      • getReasonOfRemoval

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