core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

package spark.scheduler.cluster

import scala.collection.mutable.ArrayBuffer
import spark.scheduler._
import spark.TaskState.TaskState
import java.nio.ByteBuffer

private[spark] trait TaskSetManager extends Schedulable {
  def taskSet: TaskSet
  def slaveOffer(execId: String, hostPort: String, availableCpus: Double,
    overrideLocality: TaskLocality.TaskLocality = null): Option[TaskDescription]
  def numPendingTasksForHostPort(hostPort: String): Int
  def numRackLocalPendingTasksForHost(hostPort :String): Int
  def numPendingTasksForHost(hostPort: String): Int
  def statusUpdate(tid: Long, state: TaskState, serializedData: ByteBuffer)
  def error(message: String)
}