spark-instrumented-optimizer/core/src/main/scala/spark/Scheduler.scala

package spark

// Scheduler trait, implemented by both NexusScheduler and LocalScheduler.
private trait Scheduler {
  def start()
  def waitForRegister()
  def runTasks[T](tasks: Array[Task[T]])(implicit m: ClassManifest[T]): Array[T]
  def stop()
  def numCores(): Int
}