Package org.apache.spark.util

Class MetricUtils

Object
org.apache.spark.util.MetricUtils
public class MetricUtils extends Object

  • Constructor Details

    • MetricUtils

      public MetricUtils()

  • Method Details

    • SUM_METRIC

      public static String SUM_METRIC()

    • SIZE_METRIC

      public static String SIZE_METRIC()

    • TIMING_METRIC

      public static String TIMING_METRIC()

    • NS_TIMING_METRIC

      public static String NS_TIMING_METRIC()

    • AVERAGE_METRIC

      public static String AVERAGE_METRIC()

    • metricNeedsMax

      public static boolean metricNeedsMax(String metricsType)

    • stringValue

      public static String stringValue(String metricsType, long[] values, long[] maxMetrics)
      A function that defines how we aggregate the final accumulator results among all tasks, and represent it in string for a SQL physical operator.
      Parameters:
      metricsType - (undocumented)
      values - (undocumented)
      maxMetrics - (undocumented)
      Returns:
      (undocumented)