public class CountCumSum
extends java.lang.Object
Constructor and Description |
---|
CountCumSum(org.apache.spark.api.java.JavaRDD<java.util.concurrent.atomic.AtomicLong> sentenceCountRDD) |
Modifier and Type | Method and Description |
---|---|
void |
actionForMapPartition(org.apache.spark.api.java.JavaRDD rdd) |
org.apache.spark.api.java.JavaRDD<java.lang.Long> |
buildCumSum() |
void |
cumSumBetweenPartition() |
void |
cumSumWithinPartition() |
org.apache.spark.api.java.JavaRDD<java.lang.Long> |
getCumSumRDD() |
public CountCumSum(org.apache.spark.api.java.JavaRDD<java.util.concurrent.atomic.AtomicLong> sentenceCountRDD)
public org.apache.spark.api.java.JavaRDD<java.lang.Long> getCumSumRDD()
public void actionForMapPartition(org.apache.spark.api.java.JavaRDD rdd)
public void cumSumWithinPartition()
public void cumSumBetweenPartition()
public org.apache.spark.api.java.JavaRDD<java.lang.Long> buildCumSum()