public class UpdateWordFreqAccumulatorFunction extends java.lang.Object implements org.apache.spark.api.java.function.Function<java.util.List<java.lang.String>,Pair<java.util.List<java.lang.String>,java.util.concurrent.atomic.AtomicLong>>
Constructor and Description |
---|
UpdateWordFreqAccumulatorFunction(org.apache.spark.broadcast.Broadcast<java.util.List<java.lang.String>> stopWords,
org.apache.spark.Accumulator<Counter<java.lang.String>> wordFreqAcc) |
Modifier and Type | Method and Description |
---|---|
Pair<java.util.List<java.lang.String>,java.util.concurrent.atomic.AtomicLong> |
call(java.util.List<java.lang.String> lstOfWords) |
public UpdateWordFreqAccumulatorFunction(org.apache.spark.broadcast.Broadcast<java.util.List<java.lang.String>> stopWords, org.apache.spark.Accumulator<Counter<java.lang.String>> wordFreqAcc)
public Pair<java.util.List<java.lang.String>,java.util.concurrent.atomic.AtomicLong> call(java.util.List<java.lang.String> lstOfWords) throws java.lang.Exception
call
in interface org.apache.spark.api.java.function.Function<java.util.List<java.lang.String>,Pair<java.util.List<java.lang.String>,java.util.concurrent.atomic.AtomicLong>>
java.lang.Exception