Package org.apache.spark.util

Class MetricUtils

Object

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 boolean	metricNeedsMax(String metricsType)
static String	NS_TIMING_METRIC()
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)