org.apache.spark.ui.jobs

Class ApiHelper

Object

org.apache.spark.ui.jobs.ApiHelper

public class ApiHelper
extends Object

Constructor Summary

Constructors

Constructor and Description
ApiHelper()

Method Summary

Modifier and Type	Method and Description
static boolean	hasAccumulators(StageData stageData)
static boolean	hasBytesSpilled(StageData stageData)
static boolean	hasInput(StageData stageData)
static boolean	hasOutput(StageData stageData)
static boolean	hasShuffleRead(StageData stageData)
static boolean	hasShuffleWrite(StageData stageData)
static String	HEADER_ACCUMULATORS()
static String	HEADER_ATTEMPT()
static String	HEADER_DESER_TIME()
static String	HEADER_DISK_SPILL()
static String	HEADER_DURATION()
static String	HEADER_ERROR()
static String	HEADER_EXECUTOR()
static String	HEADER_GC_TIME()
static String	HEADER_GETTING_RESULT_TIME()
static String	HEADER_HOST()
static String	HEADER_ID()
static String	HEADER_INPUT_SIZE()
static String	HEADER_LAUNCH_TIME()
static String	HEADER_LOCALITY()
static String	HEADER_MEM_SPILL()
static String	HEADER_OUTPUT_SIZE()
static String	HEADER_PEAK_MEM()
static String	HEADER_SCHEDULER_DELAY()
static String	HEADER_SER_TIME()
static String	HEADER_SHUFFLE_READ_FETCH_WAIT_TIME()
static String	HEADER_SHUFFLE_REMOTE_READS()
static String	HEADER_SHUFFLE_TOTAL_READS()
static String	HEADER_SHUFFLE_WRITE_SIZE()
static String	HEADER_SHUFFLE_WRITE_TIME()
static String	HEADER_STATUS()
static String	HEADER_TASK_INDEX()
static scala.Option<String>	indexName(String sortColumn)
static scala.Tuple2<String,String>	lastStageNameAndDescription(org.apache.spark.status.AppStatusStore store, JobData job)
static long	totalBytesRead(ShuffleReadMetrics metrics)

Methods inherited from class Object

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

Constructor Detail

ApiHelper

public ApiHelper()

Method Detail

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)