org.apache.spark.scheduler

Class JobSubmitted

Object

org.apache.spark.scheduler.JobSubmitted

All Implemented Interfaces:

java.io.Serializable, DAGSchedulerEvent, scala.Equals, scala.Product

public class JobSubmitted
extends Object
implements DAGSchedulerEvent, scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

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)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	allowLocal()
CallSite	callSite()
Object	finalRDD()
Object	func()
int	jobId()
JobListener	listener()
int[]	partitions()
java.util.Properties	properties()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

JobSubmitted

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)

Method Detail

jobId

public int jobId()

finalRDD

public Object finalRDD()

func

public Object func()

partitions

public int[] partitions()

allowLocal

public boolean allowLocal()

callSite

public CallSite callSite()

listener

public JobListener listener()

properties

public java.util.Properties properties()