public class WordFreqAccumulator extends java.lang.Object implements org.apache.spark.AccumulatorParam<Counter<java.lang.String>>
org.apache.spark.AccumulatorParam.DoubleAccumulatorParam$, org.apache.spark.AccumulatorParam.FloatAccumulatorParam$, org.apache.spark.AccumulatorParam.IntAccumulatorParam$, org.apache.spark.AccumulatorParam.LongAccumulatorParam$
Constructor and Description |
---|
WordFreqAccumulator() |
Modifier and Type | Method and Description |
---|---|
Counter<java.lang.String> |
addAccumulator(Counter<java.lang.String> c1,
Counter<java.lang.String> c2) |
Counter<java.lang.String> |
addInPlace(Counter<java.lang.String> c1,
Counter<java.lang.String> c2) |
Counter<java.lang.String> |
zero(Counter<java.lang.String> initialCounter) |
public Counter<java.lang.String> addInPlace(Counter<java.lang.String> c1, Counter<java.lang.String> c2)