public class ElementsFrequenciesAccumulator extends java.lang.Object implements org.apache.spark.AccumulatorParam<Counter<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 |
---|
ElementsFrequenciesAccumulator() |
Modifier and Type | Method and Description |
---|---|
Counter<java.lang.Long> |
addAccumulator(Counter<java.lang.Long> c1,
Counter<java.lang.Long> c2) |
Counter<java.lang.Long> |
addInPlace(Counter<java.lang.Long> r1,
Counter<java.lang.Long> r2) |
Counter<java.lang.Long> |
zero(Counter<java.lang.Long> initialValue) |