Class InternalAccumulator

Object
org.apache.spark.InternalAccumulator

public class InternalAccumulator extends Object
A collection of fields and methods concerned with internal accumulators that represent task level metrics.
  • Constructor Details

    • InternalAccumulator

      public InternalAccumulator()
  • Method Details

    • METRICS_PREFIX

      public static String METRICS_PREFIX()
    • SHUFFLE_READ_METRICS_PREFIX

      public static String SHUFFLE_READ_METRICS_PREFIX()
    • SHUFFLE_WRITE_METRICS_PREFIX

      public static String SHUFFLE_WRITE_METRICS_PREFIX()
    • OUTPUT_METRICS_PREFIX

      public static String OUTPUT_METRICS_PREFIX()
    • INPUT_METRICS_PREFIX

      public static String INPUT_METRICS_PREFIX()
    • SHUFFLE_PUSH_READ_METRICS_PREFIX

      public static String SHUFFLE_PUSH_READ_METRICS_PREFIX()
    • EXECUTOR_DESERIALIZE_TIME

      public static String EXECUTOR_DESERIALIZE_TIME()
    • EXECUTOR_DESERIALIZE_CPU_TIME

      public static String EXECUTOR_DESERIALIZE_CPU_TIME()
    • EXECUTOR_RUN_TIME

      public static String EXECUTOR_RUN_TIME()
    • EXECUTOR_CPU_TIME

      public static String EXECUTOR_CPU_TIME()
    • RESULT_SIZE

      public static String RESULT_SIZE()
    • JVM_GC_TIME

      public static String JVM_GC_TIME()
    • RESULT_SERIALIZATION_TIME

      public static String RESULT_SERIALIZATION_TIME()
    • MEMORY_BYTES_SPILLED

      public static String MEMORY_BYTES_SPILLED()
    • DISK_BYTES_SPILLED

      public static String DISK_BYTES_SPILLED()
    • PEAK_EXECUTION_MEMORY

      public static String PEAK_EXECUTION_MEMORY()
    • UPDATED_BLOCK_STATUSES

      public static String UPDATED_BLOCK_STATUSES()
    • TEST_ACCUM

      public static String TEST_ACCUM()