blob: 03274167e15578b5b170334bf04d1c3c88995a37 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
|
package spark
@serializable
class TaskContext(val stageId: Int, val splitId: Int, val attemptId: Int) {
}
@serializable
abstract class Task[T] {
def run (id: Int): T
def preferredLocations: Seq[String] = Nil
def generation: Option[Long] = None
}
|
