public class InternalAccumulator
extends Object
Modifier and Type | Class and Description |
---|---|
static class |
InternalAccumulator.input$ |
static class |
InternalAccumulator.output$ |
static class |
InternalAccumulator.shuffleRead$ |
static class |
InternalAccumulator.shuffleWrite$ |
Constructor and Description |
---|
InternalAccumulator() |
Modifier and Type | Method and Description |
---|---|
static String |
DISK_BYTES_SPILLED() |
static String |
EXECUTOR_CPU_TIME() |
static String |
EXECUTOR_DESERIALIZE_CPU_TIME() |
static String |
EXECUTOR_DESERIALIZE_TIME() |
static String |
EXECUTOR_RUN_TIME() |
static String |
INPUT_METRICS_PREFIX() |
static String |
JVM_GC_TIME() |
static String |
MEMORY_BYTES_SPILLED() |
static String |
METRICS_PREFIX() |
static String |
OUTPUT_METRICS_PREFIX() |
static String |
PEAK_EXECUTION_MEMORY() |
static String |
RESULT_SERIALIZATION_TIME() |
static String |
RESULT_SIZE() |
static String |
SHUFFLE_READ_METRICS_PREFIX() |
static String |
SHUFFLE_WRITE_METRICS_PREFIX() |
static String |
TEST_ACCUM() |
static String |
UPDATED_BLOCK_STATUSES() |
public static String METRICS_PREFIX()
public static String SHUFFLE_READ_METRICS_PREFIX()
public static String SHUFFLE_WRITE_METRICS_PREFIX()
public static String OUTPUT_METRICS_PREFIX()
public static String INPUT_METRICS_PREFIX()
public static String EXECUTOR_DESERIALIZE_TIME()
public static String EXECUTOR_DESERIALIZE_CPU_TIME()
public static String EXECUTOR_RUN_TIME()
public static String EXECUTOR_CPU_TIME()
public static String RESULT_SIZE()
public static String JVM_GC_TIME()
public static String RESULT_SERIALIZATION_TIME()
public static String MEMORY_BYTES_SPILLED()
public static String DISK_BYTES_SPILLED()
public static String PEAK_EXECUTION_MEMORY()
public static String UPDATED_BLOCK_STATUSES()
public static String TEST_ACCUM()