Package org.apache.spark.util

Class DoubleAccumulator

Object

org.apache.spark.util.AccumulatorV2<Double,Double>

org.apache.spark.util.DoubleAccumulator

All Implemented Interfaces:

Serializable

public class DoubleAccumulator
extends AccumulatorV2<Double,Double>

An accumulator for computing sum, count, and averages for double precision floating numbers.

Since:

2.0.0

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DoubleAccumulator()

Method Summary

Modifier and Type	Method	Description
void	add(double v)	Adds v to the accumulator, i.e.
void	add(Double v)	Adds v to the accumulator, i.e.
double	avg()	Returns the average of elements added to the accumulator.
DoubleAccumulator	copy()	Creates a new copy of this accumulator.
long	count()	Returns the number of elements added to the accumulator.
boolean	isZero()	Returns false if this accumulator has had any values added to it or the sum is non-zero.
void	merge(AccumulatorV2<Double,Double> other)	Merges another same-type accumulator into this one and update its state, i.e.
void	reset()	Resets this accumulator, which is zero value.
double	sum()	Returns the sum of elements added to the accumulator.
Double	value()	Defines the current value of this accumulator

Methods inherited from class org.apache.spark.util.AccumulatorV2

copyAndReset, excludeFromHeartbeat, id, isRegistered, name, toString

Methods inherited from class java.lang.Object

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

Constructor Details

DoubleAccumulator

public DoubleAccumulator()

Method Details

add

public void add(Double v)

Adds v to the accumulator, i.e. increment sum by v and count by 1.

Specified by:

add in class AccumulatorV2<Double,Double>

Parameters:

v - (undocumented)

Since:

2.0.0

add

public void add(double v)

Adds v to the accumulator, i.e. increment sum by v and count by 1.

Parameters:

v - (undocumented)

Since:

2.0.0

avg

public double avg()

Returns the average of elements added to the accumulator.

Returns:

(undocumented)

Since:

2.0.0

copy

public DoubleAccumulator copy()

Description copied from class: AccumulatorV2

Creates a new copy of this accumulator.

Specified by:

copy in class AccumulatorV2<Double,Double>

Returns:

(undocumented)

count

public long count()

Returns the number of elements added to the accumulator.

Returns:

(undocumented)

Since:

2.0.0

isZero

public boolean isZero()

Returns false if this accumulator has had any values added to it or the sum is non-zero.

Specified by:

isZero in class AccumulatorV2<Double,Double>

Returns:

(undocumented)

merge

public void merge(AccumulatorV2<Double,Double> other)

Description copied from class: AccumulatorV2

Merges another same-type accumulator into this one and update its state, i.e. this should be merge-in-place.

Specified by:

merge in class AccumulatorV2<Double,Double>

Parameters:

other - (undocumented)

reset

public void reset()

Description copied from class: AccumulatorV2

Resets this accumulator, which is zero value. i.e. call isZero must return true.

Specified by:

reset in class AccumulatorV2<Double,Double>

sum

public double sum()

Returns the sum of elements added to the accumulator.

Returns:

(undocumented)

Since:

2.0.0

value

public Double value()

Description copied from class: AccumulatorV2

Defines the current value of this accumulator

Specified by:

value in class AccumulatorV2<Double,Double>

Returns:

(undocumented)