Package org.apache.spark.status

Class TaskIndexNames

Object
org.apache.spark.status.TaskIndexNames
public class TaskIndexNames extends Object
Tasks have a lot of indices that are used in a few different places. This object keeps logical names for these indices, mapped to short strings to save space when using a disk store.

  • Constructor Details

    • TaskIndexNames

      public TaskIndexNames()

  • Method Details

    • ACCUMULATORS

      public static final String ACCUMULATORS()

    • ATTEMPT

      public static final String ATTEMPT()

    • DESER_CPU_TIME

      public static final String DESER_CPU_TIME()

    • DESER_TIME

      public static final String DESER_TIME()

    • DISK_SPILL

      public static final String DISK_SPILL()

    • DURATION

      public static final String DURATION()

    • ERROR

      public static final String ERROR()

    • EXECUTOR

      public static final String EXECUTOR()

    • HOST

      public static final String HOST()

    • EXEC_CPU_TIME

      public static final String EXEC_CPU_TIME()

    • EXEC_RUN_TIME

      public static final String EXEC_RUN_TIME()

    • GC_TIME

      public static final String GC_TIME()

    • GETTING_RESULT_TIME

      public static final String GETTING_RESULT_TIME()

    • INPUT_RECORDS

      public static final String INPUT_RECORDS()

    • INPUT_SIZE

      public static final String INPUT_SIZE()

    • LAUNCH_TIME

      public static final String LAUNCH_TIME()

    • LOCALITY

      public static final String LOCALITY()

    • MEM_SPILL

      public static final String MEM_SPILL()

    • OUTPUT_RECORDS

      public static final String OUTPUT_RECORDS()

    • OUTPUT_SIZE

      public static final String OUTPUT_SIZE()

    • PEAK_MEM

      public static final String PEAK_MEM()

    • RESULT_SIZE

      public static final String RESULT_SIZE()

    • SCHEDULER_DELAY

      public static final String SCHEDULER_DELAY()

    • SER_TIME

      public static final String SER_TIME()

    • SHUFFLE_LOCAL_BLOCKS

      public static final String SHUFFLE_LOCAL_BLOCKS()

    • SHUFFLE_READ_RECORDS

      public static final String SHUFFLE_READ_RECORDS()

    • SHUFFLE_READ_FETCH_WAIT_TIME

      public static final String SHUFFLE_READ_FETCH_WAIT_TIME()

    • SHUFFLE_REMOTE_BLOCKS

      public static final String SHUFFLE_REMOTE_BLOCKS()

    • SHUFFLE_REMOTE_READS

      public static final String SHUFFLE_REMOTE_READS()

    • SHUFFLE_REMOTE_READS_TO_DISK

      public static final String SHUFFLE_REMOTE_READS_TO_DISK()

    • SHUFFLE_TOTAL_READS

      public static final String SHUFFLE_TOTAL_READS()

    • SHUFFLE_TOTAL_BLOCKS

      public static final String SHUFFLE_TOTAL_BLOCKS()

    • SHUFFLE_WRITE_RECORDS

      public static final String SHUFFLE_WRITE_RECORDS()

    • SHUFFLE_WRITE_SIZE

      public static final String SHUFFLE_WRITE_SIZE()

    • SHUFFLE_WRITE_TIME

      public static final String SHUFFLE_WRITE_TIME()

    • SHUFFLE_REMOTE_REQS_DURATION

      public static final String SHUFFLE_REMOTE_REQS_DURATION()

    • SHUFFLE_PUSH_CORRUPT_MERGED_BLOCK_CHUNKS

      public static final String SHUFFLE_PUSH_CORRUPT_MERGED_BLOCK_CHUNKS()

    • SHUFFLE_PUSH_MERGED_FETCH_FALLBACK_COUNT

      public static final String SHUFFLE_PUSH_MERGED_FETCH_FALLBACK_COUNT()

    • SHUFFLE_PUSH_MERGED_REMOTE_BLOCKS

      public static final String SHUFFLE_PUSH_MERGED_REMOTE_BLOCKS()

    • SHUFFLE_PUSH_MERGED_LOCAL_BLOCKS

      public static final String SHUFFLE_PUSH_MERGED_LOCAL_BLOCKS()

    • SHUFFLE_PUSH_MERGED_REMOTE_CHUNKS

      public static final String SHUFFLE_PUSH_MERGED_REMOTE_CHUNKS()

    • SHUFFLE_PUSH_MERGED_LOCAL_CHUNKS

      public static final String SHUFFLE_PUSH_MERGED_LOCAL_CHUNKS()

    • SHUFFLE_PUSH_MERGED_REMOTE_READS

      public static final String SHUFFLE_PUSH_MERGED_REMOTE_READS()

    • SHUFFLE_PUSH_MERGED_LOCAL_READS

      public static final String SHUFFLE_PUSH_MERGED_LOCAL_READS()

    • SHUFFLE_PUSH_MERGED_REMOTE_REQS_DURATION

      public static final String SHUFFLE_PUSH_MERGED_REMOTE_REQS_DURATION()

    • STAGE

      public static final String STAGE()

    • STATUS

      public static final String STATUS()

    • TASK_INDEX

      public static final String TASK_INDEX()

    • TASK_PARTITION_ID

      public static final String TASK_PARTITION_ID()

    • COMPLETION_TIME

      public static final String COMPLETION_TIME()