Class SparkListenerStageExecutorMetrics

All Implemented Interfaces:
Serializable, SparkListenerEvent, scala.Equals, scala.Product, scala.Serializable

public class SparkListenerStageExecutorMetrics extends Object implements SparkListenerEvent, scala.Product, scala.Serializable
Peak metric values for the executor for the stage, written to the history log at stage completion. param: execId executor id param: stageId stage id param: stageAttemptId stage attempt param: executorMetrics executor level metrics peak values
See Also:
  • Constructor Details

    • SparkListenerStageExecutorMetrics

      public SparkListenerStageExecutorMetrics(String execId, int stageId, int stageAttemptId, org.apache.spark.executor.ExecutorMetrics executorMetrics)
  • Method Details

    • apply

      public abstract static R apply(T1 v1, T2 v2, T3 v3, T4 v4)
    • toString

      public static String toString()
    • execId

      public String execId()
    • stageId

      public int stageId()
    • stageAttemptId

      public int stageAttemptId()
    • executorMetrics

      public org.apache.spark.executor.ExecutorMetrics executorMetrics()