MetricUtils (Spark 4.2.0-preview4 JavaDoc)

org.apache.spark.util.MetricUtils

public class MetricUtils extends Object

Constructor Summary

Constructors

Constructor

Description

MetricUtils()
Method Summary

Modifier and Type

Method

Description

static String

AVERAGE_METRIC()

static org.apache.spark.internal.Logging.LogStringContext

LogStringContext(scala.StringContext sc)

static boolean

metricNeedsMax(String metricsType)

static String

NS_TIMING_METRIC()

static org.slf4j.Logger

org$apache$spark$internal$Logging$$log_()

static void

org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)

static String

SIZE_METRIC()

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.

static String

SUM_METRIC()

static String

TIMING_METRIC()

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)
- org$apache$spark$internal$Logging$$log_
  
  public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()
- org$apache$spark$internal$Logging$$log__$eq
  
  public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
- LogStringContext
  
  public static org.apache.spark.internal.Logging.LogStringContext LogStringContext(scala.StringContext sc)