Class JobStart
- java.lang.Object
-
- org.apache.wayang.spark.monitoring.metrics.JobStart
-
- All Implemented Interfaces:
java.io.Serializable
,Job
,SerializableObject
public class JobStart extends java.lang.Object implements Job, SerializableObject
JobStart class represents a job's start in a system. It implements the Job and SerializableObject interfaces.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description JobStart()
-
Method Summary
All Methods Instance Methods Concrete 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
public void setEventame(java.lang.String name)
Description copied from interface:Job
Sets the name of the event associated with this job.- Specified by:
setEventame
in interfaceJob
- Parameters:
name
- the name of the event
-
getEventName
public java.lang.String getEventName()
Description copied from interface:Job
Returns the name of the event associated with this job.- Specified by:
getEventName
in interfaceJob
- Returns:
- the name of the event
-
setJobID
public void setJobID(int jobID)
Description copied from interface:Job
Sets the unique identifier for this job.
-
getJobID
public int getJobID()
Description copied from 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 interfaceJob
- 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 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:Job
Sets the stage ID associated with this job.- Specified by:
setStageID
in interfaceJob
- Parameters:
stageId
- the stage ID associated with this job
-
getStageID
public scala.collection.Seq<java.lang.Object> getStageID()
Description copied from interface:Job
Returns the stage ID associated with this job.- Specified by:
getStageID
in interfaceJob
- Returns:
- the stage ID associated with this job
-
setListOfStages
public void setListOfStages(java.util.List<Stage> listOfStages)
Description copied from interface:Job
Sets the list of stages comprising this job.- Specified by:
setListOfStages
in interfaceJob
- Parameters:
listOfStages
- the list of stages comprising this job
-
getListOfStages
public java.util.List<Stage> getListOfStages()
Description copied from interface:Job
Returns the list of stages comprising this job.- Specified by:
getListOfStages
in interfaceJob
- Returns:
- the list of stages comprising this job
-
-