org.apache.spark

Class GrowableAccumulableParam<R,T>

Object

org.apache.spark.GrowableAccumulableParam<R,T>

All Implemented Interfaces:

java.io.Serializable, AccumulableParam<R,T>

public class GrowableAccumulableParam<R,T>
extends Object
implements AccumulableParam<R,T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GrowableAccumulableParam(scala.Function1<R,scala.collection.generic.Growable<T>> evidence$1, scala.reflect.ClassTag<R> evidence$2)

Method Summary

Methods

Modifier and Type	Method and Description
R	addAccumulator(R growable, T elem) Add additional data to the accumulator value.
R	addInPlace(R t1, R t2) Merge two accumulated values together.
R	zero(R initialValue) Return the "zero" (identity) value for an accumulator type, given its initial value.

Methods inherited from class Object

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

Constructor Detail

GrowableAccumulableParam

public GrowableAccumulableParam(scala.Function1<R,scala.collection.generic.Growable<T>> evidence$1,
                        scala.reflect.ClassTag<R> evidence$2)

Method Detail

addAccumulator

public R addAccumulator(R growable,
               T elem)

Description copied from interface: AccumulableParam

Add additional data to the accumulator value. Is allowed to modify and return r for efficiency (to avoid allocating objects).

Specified by:

addAccumulator in interface AccumulableParam<R,T>

Parameters:

growable - the current value of the accumulator

elem - the data to be added to the accumulator

Returns:

the new value of the accumulator

addInPlace

public R addInPlace(R t1,
           R t2)

Description copied from interface: AccumulableParam

Merge two accumulated values together. Is allowed to modify and return the first value for efficiency (to avoid allocating objects).

Specified by:

addInPlace in interface AccumulableParam<R,T>

Parameters:

t1 - one set of accumulated data

t2 - another set of accumulated data

Returns:

both data sets merged together

zero

public R zero(R initialValue)

Description copied from interface: AccumulableParam

Return the "zero" (identity) value for an accumulator type, given its initial value. For example, if R was a vector of N dimensions, this would return a vector of N zeroes.

Specified by:

zero in interface AccumulableParam<R,T>