blob: b9f3128c822c8fea988e1d723574db4b42b63781 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
|
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
}
|
