public class InternalAccumulator
extends java.lang.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 java.lang.String |
DISK_BYTES_SPILLED() |
static java.lang.String |
EXECUTOR_DESERIALIZE_TIME() |
static java.lang.String |
EXECUTOR_RUN_TIME() |
static java.lang.String |
INPUT_METRICS_PREFIX() |
static java.lang.String |
JVM_GC_TIME() |
static java.lang.String |
MEMORY_BYTES_SPILLED() |
static java.lang.String |
METRICS_PREFIX() |
static java.lang.String |
OUTPUT_METRICS_PREFIX() |
static java.lang.String |
PEAK_EXECUTION_MEMORY() |
static java.lang.String |
RESULT_SERIALIZATION_TIME() |
static java.lang.String |
RESULT_SIZE() |
static java.lang.String |
SHUFFLE_READ_METRICS_PREFIX() |
static java.lang.String |
SHUFFLE_WRITE_METRICS_PREFIX() |
static java.lang.String |
TEST_ACCUM() |
static java.lang.String |
UPDATED_BLOCK_STATUSES() |
public static java.lang.String METRICS_PREFIX()
public static java.lang.String SHUFFLE_READ_METRICS_PREFIX()
public static java.lang.String SHUFFLE_WRITE_METRICS_PREFIX()
public static java.lang.String OUTPUT_METRICS_PREFIX()
public static java.lang.String INPUT_METRICS_PREFIX()
public static java.lang.String EXECUTOR_DESERIALIZE_TIME()
public static java.lang.String EXECUTOR_RUN_TIME()
public static java.lang.String RESULT_SIZE()
public static java.lang.String JVM_GC_TIME()
public static java.lang.String RESULT_SERIALIZATION_TIME()
public static java.lang.String MEMORY_BYTES_SPILLED()
public static java.lang.String DISK_BYTES_SPILLED()
public static java.lang.String PEAK_EXECUTION_MEMORY()
public static java.lang.String UPDATED_BLOCK_STATUSES()
public static java.lang.String TEST_ACCUM()