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

Interface Job

All Superinterfaces:
Serializable
All Known Implementing Classes:
JobEnd, JobStart
public interface Job extends 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

    Modifier and Type
    Method
    Description
    String
    getEventName()
    Returns the name of the event associated with this job.
    int
    getJobID()
    Returns the unique identifier for this job.
    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<Object>
    getStageID()
    Returns the stage ID associated with this job.
    void
    setEventame(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(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<Object> stageId)
    Sets the stage ID associated with this job.

  • Method Details

    • setEventame

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

    • getEventName

      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<Object> stageId)
      Sets the stage ID associated with this job.
      Parameters:
      stageId - the stage ID associated with this job

    • getStageID

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

    • setListOfStages

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

    • getListOfStages

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