org.apache.spark.scheduler

Class TaskSet

Object

org.apache.spark.scheduler.TaskSet

public class TaskSet
extends Object

A set of tasks submitted together to the low-level TaskScheduler, usually representing missing partitions of a particular stage.

Constructor Summary

Constructors

Constructor and Description
TaskSet(Task<?>[] tasks, int stageId, int attempt, int priority, java.util.Properties properties)

Method Summary

Methods

Modifier and Type	Method and Description
int	attempt()
String	id()
int	priority()
java.util.Properties	properties()
int	stageId()
Task<?>[]	tasks()
String	toString()

Methods inherited from class Object

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

Constructor Detail

TaskSet

public TaskSet(Task<?>[] tasks,
       int stageId,
       int attempt,
       int priority,
       java.util.Properties properties)

Method Detail

tasks

public Task<?>[] tasks()

stageId

public int stageId()

attempt

public int attempt()

priority

public int priority()

properties

public java.util.Properties properties()

id

public String id()

toString

public String toString()

Overrides:

toString in class Object