public class ExtraElementsFrequenciesAccumulator extends java.lang.Object implements org.apache.spark.AccumulatorParam<ExtraCounter<java.lang.Long>>
org.apache.spark.AccumulatorParam.DoubleAccumulatorParam$, org.apache.spark.AccumulatorParam.FloatAccumulatorParam$, org.apache.spark.AccumulatorParam.IntAccumulatorParam$, org.apache.spark.AccumulatorParam.LongAccumulatorParam$
Constructor and Description |
---|
ExtraElementsFrequenciesAccumulator() |
Modifier and Type | Method and Description |
---|---|
ExtraCounter<java.lang.Long> |
addAccumulator(ExtraCounter<java.lang.Long> c1,
ExtraCounter<java.lang.Long> c2) |
ExtraCounter<java.lang.Long> |
addInPlace(ExtraCounter<java.lang.Long> r1,
ExtraCounter<java.lang.Long> r2) |
ExtraCounter<java.lang.Long> |
zero(ExtraCounter<java.lang.Long> initialValue) |
public ExtraCounter<java.lang.Long> addAccumulator(ExtraCounter<java.lang.Long> c1, ExtraCounter<java.lang.Long> c2)
addAccumulator
in interface org.apache.spark.AccumulableParam<ExtraCounter<java.lang.Long>,ExtraCounter<java.lang.Long>>
addAccumulator
in interface org.apache.spark.AccumulatorParam<ExtraCounter<java.lang.Long>>
public ExtraCounter<java.lang.Long> addInPlace(ExtraCounter<java.lang.Long> r1, ExtraCounter<java.lang.Long> r2)
addInPlace
in interface org.apache.spark.AccumulableParam<ExtraCounter<java.lang.Long>,ExtraCounter<java.lang.Long>>
public ExtraCounter<java.lang.Long> zero(ExtraCounter<java.lang.Long> initialValue)
zero
in interface org.apache.spark.AccumulableParam<ExtraCounter<java.lang.Long>,ExtraCounter<java.lang.Long>>