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 Summary

Constructors

Constructor and Description
TaskIndexNames()

Method Summary

Modifier and Type	Method and Description
static String	ACCUMULATORS()
static String	ATTEMPT()
static String	COMPLETION_TIME()
static String	DESER_CPU_TIME()
static String	DESER_TIME()
static String	DISK_SPILL()
static String	DURATION()
static String	ERROR()
static String	EXEC_CPU_TIME()
static String	EXEC_RUN_TIME()
static String	EXECUTOR()
static String	GC_TIME()
static String	GETTING_RESULT_TIME()
static String	HOST()
static String	INPUT_RECORDS()
static String	INPUT_SIZE()
static String	LAUNCH_TIME()
static String	LOCALITY()
static String	MEM_SPILL()
static String	OUTPUT_RECORDS()
static String	OUTPUT_SIZE()
static String	PEAK_MEM()
static String	RESULT_SIZE()
static String	SCHEDULER_DELAY()
static String	SER_TIME()
static String	SHUFFLE_LOCAL_BLOCKS()
static String	SHUFFLE_PUSH_CORRUPT_MERGED_BLOCK_CHUNKS()
static String	SHUFFLE_PUSH_MERGED_FETCH_FALLBACK_COUNT()
static String	SHUFFLE_PUSH_MERGED_LOCAL_BLOCKS()
static String	SHUFFLE_PUSH_MERGED_LOCAL_CHUNKS()
static String	SHUFFLE_PUSH_MERGED_LOCAL_READS()
static String	SHUFFLE_PUSH_MERGED_REMOTE_BLOCKS()
static String	SHUFFLE_PUSH_MERGED_REMOTE_CHUNKS()
static String	SHUFFLE_PUSH_MERGED_REMOTE_READS()
static String	SHUFFLE_PUSH_MERGED_REMOTE_REQS_DURATION()
static String	SHUFFLE_READ_FETCH_WAIT_TIME()
static String	SHUFFLE_READ_RECORDS()
static String	SHUFFLE_REMOTE_BLOCKS()
static String	SHUFFLE_REMOTE_READS_TO_DISK()
static String	SHUFFLE_REMOTE_READS()
static String	SHUFFLE_REMOTE_REQS_DURATION()
static String	SHUFFLE_TOTAL_BLOCKS()
static String	SHUFFLE_TOTAL_READS()
static String	SHUFFLE_WRITE_RECORDS()
static String	SHUFFLE_WRITE_SIZE()
static String	SHUFFLE_WRITE_TIME()
static String	STAGE()
static String	STATUS()
static String	TASK_INDEX()
static String	TASK_PARTITION_ID()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskIndexNames

public TaskIndexNames()

Method Detail

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