Package org.apache.spark.metrics.source

Class DoubleAccumulatorSource

Object

org.apache.spark.metrics.source.DoubleAccumulatorSource

All Implemented Interfaces:

Source

public class DoubleAccumulatorSource
extends Object

Constructor Summary

Constructors

Constructor	Description
DoubleAccumulatorSource()

Method Summary

Modifier and Type	Method	Description
com.codahale.metrics.MetricRegistry	metricRegistry()
static void	register(SparkContext sc, scala.collection.immutable.Map<String,DoubleAccumulator> accumulators)
String	sourceName()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DoubleAccumulatorSource

public DoubleAccumulatorSource()

Method Details

register

public static void register(SparkContext sc,
 scala.collection.immutable.Map<String,DoubleAccumulator> accumulators)

metricRegistry

public com.codahale.metrics.MetricRegistry metricRegistry()

Specified by:

metricRegistry in interface Source

sourceName

public String sourceName()

Specified by:

sourceName in interface Source