Class JobEnd
- java.lang.Object
-
- org.apache.wayang.spark.monitoring.metrics.JobEnd
-
- All Implemented Interfaces:
java.io.Serializable,Job,SerializableObject
public class JobEnd extends java.lang.Object implements Job, SerializableObject
JobEnd class represents a job's end in a system. It implements the Job and SerializableObject interfaces.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description JobEnd()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.StringgetEventName()Returns the name of the event associated with this job.intgetJobID()Returns the unique identifier for this job.java.util.List<Stage>getListOfStages()Returns the list of stages comprising this job.intgetProductArity()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.voidsetEventame(java.lang.String name)Sets the name of the event associated with this job.voidsetJobID(int jobID)Sets the unique identifier for this job.voidsetListOfStages(java.util.List<Stage> listOfStages)Sets the list of stages comprising this job.voidsetProductArity(int productArity)Sets the number of output products produced by this job.voidsetStageID(scala.collection.Seq<java.lang.Object> stageId)Sets the stage ID associated with this job.
-
-
-
Method Detail
-
setEventame
public void setEventame(java.lang.String name)
Description copied from interface:JobSets the name of the event associated with this job.- Specified by:
setEventamein interfaceJob- Parameters:
name- the name of the event
-
getEventName
public java.lang.String getEventName()
Description copied from interface:JobReturns the name of the event associated with this job.- Specified by:
getEventNamein interfaceJob- Returns:
- the name of the event
-
setJobID
public void setJobID(int jobID)
Description copied from interface:JobSets the unique identifier for this job.
-
getJobID
public int getJobID()
Description copied from interface:JobReturns the unique identifier for this job.
-
setProductArity
public void setProductArity(int productArity)
Description copied from interface:JobSets the number of output products produced by this job.- Specified by:
setProductArityin interfaceJob- Parameters:
productArity- the number of output products produced by this job
-
getProductArity
public int getProductArity()
Description copied from interface:JobReturns the number of output products produced by this job.- Specified by:
getProductArityin interfaceJob- Returns:
- the number of output products produced by this job
-
setStageID
public void setStageID(scala.collection.Seq<java.lang.Object> stageId)
Description copied from interface:JobSets the stage ID associated with this job.- Specified by:
setStageIDin interfaceJob- Parameters:
stageId- the stage ID associated with this job
-
getStageID
public scala.collection.Seq<java.lang.Object> getStageID()
Description copied from interface:JobReturns the stage ID associated with this job.- Specified by:
getStageIDin interfaceJob- Returns:
- the stage ID associated with this job
-
setListOfStages
public void setListOfStages(java.util.List<Stage> listOfStages)
Description copied from interface:JobSets the list of stages comprising this job.- Specified by:
setListOfStagesin interfaceJob- Parameters:
listOfStages- the list of stages comprising this job
-
getListOfStages
public java.util.List<Stage> getListOfStages()
Description copied from interface:JobReturns the list of stages comprising this job.- Specified by:
getListOfStagesin interfaceJob- Returns:
- the list of stages comprising this job
-
-