Package org.apache.spark.ui.jobs

Class ApiHelper

Object
org.apache.spark.ui.jobs.ApiHelper
public class ApiHelper extends Object

  • Constructor Details

    • ApiHelper

      public ApiHelper()

  • Method Details

    • HEADER_ID

      public static String HEADER_ID()

    • HEADER_TASK_INDEX

      public static String HEADER_TASK_INDEX()

    • HEADER_ATTEMPT

      public static String HEADER_ATTEMPT()

    • HEADER_STATUS

      public static String HEADER_STATUS()

    • HEADER_LOCALITY

      public static String HEADER_LOCALITY()

    • HEADER_EXECUTOR

      public static String HEADER_EXECUTOR()

    • HEADER_HOST

      public static String HEADER_HOST()

    • HEADER_LAUNCH_TIME

      public static String HEADER_LAUNCH_TIME()

    • HEADER_DURATION

      public static String HEADER_DURATION()

    • HEADER_SCHEDULER_DELAY

      public static String HEADER_SCHEDULER_DELAY()

    • HEADER_DESER_TIME

      public static String HEADER_DESER_TIME()

    • HEADER_GC_TIME

      public static String HEADER_GC_TIME()

    • HEADER_SER_TIME

      public static String HEADER_SER_TIME()

    • HEADER_GETTING_RESULT_TIME

      public static String HEADER_GETTING_RESULT_TIME()

    • HEADER_PEAK_MEM

      public static String HEADER_PEAK_MEM()

    • HEADER_ACCUMULATORS

      public static String HEADER_ACCUMULATORS()

    • HEADER_INPUT_SIZE

      public static String HEADER_INPUT_SIZE()

    • HEADER_OUTPUT_SIZE

      public static String HEADER_OUTPUT_SIZE()

    • HEADER_SHUFFLE_READ_FETCH_WAIT_TIME

      public static String HEADER_SHUFFLE_READ_FETCH_WAIT_TIME()

    • HEADER_SHUFFLE_TOTAL_READS

      public static String HEADER_SHUFFLE_TOTAL_READS()

    • HEADER_SHUFFLE_REMOTE_READS

      public static String HEADER_SHUFFLE_REMOTE_READS()

    • HEADER_SHUFFLE_WRITE_TIME

      public static String HEADER_SHUFFLE_WRITE_TIME()

    • HEADER_SHUFFLE_WRITE_SIZE

      public static String HEADER_SHUFFLE_WRITE_SIZE()

    • HEADER_MEM_SPILL

      public static String HEADER_MEM_SPILL()

    • HEADER_DISK_SPILL

      public static String HEADER_DISK_SPILL()

    • HEADER_ERROR

      public static String HEADER_ERROR()

    • hasAccumulators

      public static boolean hasAccumulators(StageData stageData)

    • hasInput

      public static boolean hasInput(StageData stageData)

    • hasOutput

      public static boolean hasOutput(StageData stageData)

    • hasShuffleRead

      public static boolean hasShuffleRead(StageData stageData)

    • hasShuffleWrite

      public static boolean hasShuffleWrite(StageData stageData)

    • hasBytesSpilled

      public static boolean hasBytesSpilled(StageData stageData)

    • totalBytesRead

      public static long totalBytesRead(ShuffleReadMetrics metrics)

    • indexName

      public static scala.Option<String> indexName(String sortColumn)

    • lastStageNameAndDescription

      public static scala.Tuple2<String,String> lastStageNameAndDescription(org.apache.spark.status.AppStatusStore store, JobData job)