org.apache.spark

Interface AccumulatorParam<T>

All Superinterfaces:

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

All Known Implementing Classes:

SparkContext.DoubleAccumulatorParam$, SparkContext.FloatAccumulatorParam$, SparkContext.IntAccumulatorParam$, SparkContext.LongAccumulatorParam$, Vector.VectorAccumParam$

public interface AccumulatorParam<T>
extends AccumulableParam<T,T>

A simpler version of AccumulableParam where the only data type you can add in is the same type as the accumulated value. An implicit AccumulatorParam object needs to be available when you create Accumulators of a specific type.

Method Summary

Methods

Modifier and Type	Method and Description
T	addAccumulator(T t1, T t2) Add additional data to the accumulator value.

Methods inherited from interface org.apache.spark.AccumulableParam

addInPlace, zero

Method Detail

addAccumulator

T addAccumulator(T t1,
               T t2)

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<T,T>

Parameters:

t1 - the current value of the accumulator

t2 - the data to be added to the accumulator

Returns:

the new value of the accumulator