Package org.apache.spark.ui.jobs
Class ApiHelper
Object
org.apache.spark.ui.jobs.ApiHelper
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic boolean
hasAccumulators
(StageData stageData) static boolean
hasBytesSpilled
(StageData stageData) static boolean
static boolean
static boolean
hasShuffleRead
(StageData stageData) static boolean
hasShuffleWrite
(StageData stageData) static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static scala.Option<String>
lastStageNameAndDescription
(org.apache.spark.status.AppStatusStore store, JobData job) static long
totalBytesRead
(ShuffleReadMetrics metrics)
-
Constructor Details
-
ApiHelper
public ApiHelper()
-
-
Method Details
-
HEADER_ID
-
HEADER_TASK_INDEX
-
HEADER_ATTEMPT
-
HEADER_STATUS
-
HEADER_LOCALITY
-
HEADER_EXECUTOR
-
HEADER_HOST
-
HEADER_LAUNCH_TIME
-
HEADER_DURATION
-
HEADER_SCHEDULER_DELAY
-
HEADER_DESER_TIME
-
HEADER_GC_TIME
-
HEADER_SER_TIME
-
HEADER_GETTING_RESULT_TIME
-
HEADER_PEAK_MEM
-
HEADER_ACCUMULATORS
-
HEADER_INPUT_SIZE
-
HEADER_OUTPUT_SIZE
-
HEADER_SHUFFLE_READ_FETCH_WAIT_TIME
-
HEADER_SHUFFLE_TOTAL_READS
-
HEADER_SHUFFLE_REMOTE_READS
-
HEADER_SHUFFLE_WRITE_TIME
-
HEADER_SHUFFLE_WRITE_SIZE
-
HEADER_MEM_SPILL
-
HEADER_DISK_SPILL
-
HEADER_ERROR
-
hasAccumulators
-
hasInput
-
hasOutput
-
hasShuffleRead
-
hasShuffleWrite
-
hasBytesSpilled
-
totalBytesRead
-
indexName
-
lastStageNameAndDescription
-