org.apache.spark.scheduler

Class ActiveJob

Object

org.apache.spark.scheduler.ActiveJob

public class ActiveJob
extends Object

Tracks information about an active job in the DAGScheduler.

Constructor Summary

Constructors

Constructor and Description
ActiveJob(int jobId, Stage finalStage, scala.Function2<TaskContext,scala.collection.Iterator<Object>,?> func, int[] partitions, CallSite callSite, JobListener listener, java.util.Properties properties)

Method Summary

Methods

Modifier and Type	Method and Description
CallSite	callSite()
Stage	finalStage()
boolean[]	finished()
Object	func()
int	jobId()
JobListener	listener()
int	numFinished()
int	numPartitions()
int[]	partitions()
java.util.Properties	properties()

Methods inherited from class Object

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

Constructor Detail

ActiveJob

public ActiveJob(int jobId,
         Stage finalStage,
         scala.Function2<TaskContext,scala.collection.Iterator<Object>,?> func,
         int[] partitions,
         CallSite callSite,
         JobListener listener,
         java.util.Properties properties)

Method Detail

jobId

public int jobId()

finalStage

public Stage finalStage()

func

public Object func()

partitions

public int[] partitions()

callSite

public CallSite callSite()

listener

public JobListener listener()

properties

public java.util.Properties properties()

numPartitions

public int numPartitions()

finished

public boolean[] finished()

numFinished

public int numFinished()