blob: 8d83ff10c420d97bd23697ceee64774e8dd93bb3 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
|
package spark.scheduler
import spark.scheduler.cluster.TaskInfo
import scala.collection._
import spark.executor.TaskMetrics
case class StageInfo(
val stage: Stage,
val taskInfos: mutable.Buffer[(TaskInfo, TaskMetrics)] = mutable.Buffer[(TaskInfo, TaskMetrics)]()
) {
override def toString = stage.rdd.toString
}
|
