package scheduler

  1. Public
  2. All

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

Value Members

  1. object RuntimePercentage extends Serializable

  2. object StatsReportListener extends Logging