org.apache.spark
Interface AccumulatorParam<T>
- All Superinterfaces:
- AccumulableParam<T,T>, java.io.Serializable
- All Known Implementing Classes:
- AccumulatorParam.DoubleAccumulatorParam$, AccumulatorParam.FloatAccumulatorParam$, AccumulatorParam.IntAccumulatorParam$, AccumulatorParam.LongAccumulatorParam$, 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 |
T |
addAccumulator(T t1,
T t2)
Add additional data to the accumulator value. |
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 accumulatort2
- the data to be added to the accumulator
- Returns:
- the new value of the accumulator