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

Class JobStart

java.lang.Object
org.apache.wayang.spark.monitoring.metrics.JobStart
All Implemented Interfaces:
Serializable, Job, SerializableObject
public class JobStart extends Object implements Job, SerializableObject
JobStart class represents a job's start in a system. It implements the Job and SerializableObject interfaces.
See Also:

  • Constructor Details

    • JobStart

      public JobStart()

  • Method Details

    • setEventame

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

    • getEventName

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

    • setJobID

      public void setJobID(int jobID)
      Description copied from interface: Job
      Sets the unique identifier for this job.
      Specified by:
      setJobID in interface Job
      Parameters:
      jobID - the unique identifier for this job

    • getJobID

      public int getJobID()
      Description copied from interface: Job
      Returns the unique identifier for this job.
      Specified by:
      getJobID in interface Job
      Returns:
      the unique identifier for this job

    • setProductArity

      public void setProductArity(int productArity)
      Description copied from interface: Job
      Sets the number of output products produced by this job.
      Specified by:
      setProductArity in interface Job
      Parameters:
      productArity - the number of output products produced by this job

    • getProductArity

      public int getProductArity()
      Description copied from interface: Job
      Returns the number of output products produced by this job.
      Specified by:
      getProductArity in interface Job
      Returns:
      the number of output products produced by this job

    • setStageID

      public void setStageID(scala.collection.Seq<Object> stageId)
      Description copied from interface: Job
      Sets the stage ID associated with this job.
      Specified by:
      setStageID in interface Job
      Parameters:
      stageId - the stage ID associated with this job

    • getStageID

      public scala.collection.Seq<Object> getStageID()
      Description copied from interface: Job
      Returns the stage ID associated with this job.
      Specified by:
      getStageID in interface Job
      Returns:
      the stage ID associated with this job

    • setListOfStages

      public void setListOfStages(List<Stage> listOfStages)
      Description copied from interface: Job
      Sets the list of stages comprising this job.
      Specified by:
      setListOfStages in interface Job
      Parameters:
      listOfStages - the list of stages comprising this job

    • getListOfStages

      public List<Stage> getListOfStages()
      Description copied from interface: Job
      Returns the list of stages comprising this job.
      Specified by:
      getListOfStages in interface Job
      Returns:
      the list of stages comprising this job