scheduler

Type Members

1. case class RuntimePercentage(executorPct: Double, fetchPct: Option[Double], other: Double) extends Product with Serializable

2. trait SparkListener extends AnyRef

3. sealed trait SparkListenerEvents extends AnyRef

4. case class StageCompleted(stageInfo: StageInfo) extends SparkListenerEvents with Product with Serializable

5. case class StageInfo(stage: Stage, taskInfos: Buffer[(TaskInfo, TaskMetrics)]) extends Product with Serializable

6. class StatsReportListener extends SparkListener with Logging

   Simple SparkListener that logs a few summary statistics when each stage completes