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()