public class JobSubmitted extends Object implements DAGSchedulerEvent, scala.Product, scala.Serializable
Constructor and Description |
---|
JobSubmitted(int jobId,
RDD<?> finalRDD,
scala.Function2<TaskContext,scala.collection.Iterator<Object>,?> func,
int[] partitions,
boolean allowLocal,
CallSite callSite,
JobListener listener,
java.util.Properties properties) |
Modifier and Type | Method and Description |
---|---|
boolean |
allowLocal() |
CallSite |
callSite() |
Object |
finalRDD() |
Object |
func() |
int |
jobId() |
JobListener |
listener() |
int[] |
partitions() |
java.util.Properties |
properties() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public JobSubmitted(int jobId, RDD<?> finalRDD, scala.Function2<TaskContext,scala.collection.Iterator<Object>,?> func, int[] partitions, boolean allowLocal, CallSite callSite, JobListener listener, java.util.Properties properties)
public int jobId()
public Object finalRDD()
public Object func()
public int[] partitions()
public boolean allowLocal()
public CallSite callSite()
public JobListener listener()
public java.util.Properties properties()