Package org.apache.wayang.spark.monitoring.interfaces

Interface Job

  • All Superinterfaces:
    java.io.Serializable
    All Known Implementing Classes:
    JobEnd, JobStart
    public interface Job
extends java.io.Serializable
    The Job interface represents a job to be executed in a distributed system. A job comprises one or more stages, and contains metadata about the job such as its ID, product arity, and event name.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      java.lang.String getEventName()
      Returns the name of the event associated with this job.
      int getJobID()
      Returns the unique identifier for this job.
      java.util.List<Stage> getListOfStages()
      Returns the list of stages comprising this job.
      int getProductArity()
      Returns the number of output products produced by this job.
      scala.collection.Seq<java.lang.Object> getStageID()
      Returns the stage ID associated with this job.
      void setEventame​(java.lang.String name)
      Sets the name of the event associated with this job.
      void setJobID​(int jobID)
      Sets the unique identifier for this job.
      void setListOfStages​(java.util.List<Stage> listOfStages)
      Sets the list of stages comprising this job.
      void setProductArity​(int productArity)
      Sets the number of output products produced by this job.
      void setStageID​(scala.collection.Seq<java.lang.Object> stageId)
      Sets the stage ID associated with this job.

    • Method Detail

      • setEventame

        void setEventame​(java.lang.String name)
        Sets the name of the event associated with this job.
        Parameters:
        name - the name of the event

      • getEventName

        java.lang.String getEventName()
        Returns the name of the event associated with this job.
        Returns:
        the name of the event

      • setJobID

        void setJobID​(int jobID)
        Sets the unique identifier for this job.
        Parameters:
        jobID - the unique identifier for this job

      • getJobID

        int getJobID()
        Returns the unique identifier for this job.
        Returns:
        the unique identifier for this job

      • setProductArity

        void setProductArity​(int productArity)
        Sets the number of output products produced by this job.
        Parameters:
        productArity - the number of output products produced by this job

      • getProductArity

        int getProductArity()
        Returns the number of output products produced by this job.
        Returns:
        the number of output products produced by this job

      • setStageID

        void setStageID​(scala.collection.Seq<java.lang.Object> stageId)
        Sets the stage ID associated with this job.
        Parameters:
        stageId - the stage ID associated with this job

      • getStageID

        scala.collection.Seq<java.lang.Object> getStageID()
        Returns the stage ID associated with this job.
        Returns:
        the stage ID associated with this job

      • setListOfStages

        void setListOfStages​(java.util.List<Stage> listOfStages)
        Sets the list of stages comprising this job.
        Parameters:
        listOfStages - the list of stages comprising this job

      • getListOfStages

        java.util.List<Stage> getListOfStages()
        Returns the list of stages comprising this job.
        Returns:
        the list of stages comprising this job