diff options
author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-01-05 22:11:28 -0500 |
---|---|---|
committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-01-05 22:11:28 -0500 |
commit | 0982572519655354b10987de4f68e29b8331bd2a (patch) | |
tree | 53afe208eef9b888a9874d25fed4f2de3b786ea9 /core/src/test | |
parent | 86af64b0a6fde5a6418727a77b43bdfeda1b81cd (diff) | |
download | spark-0982572519655354b10987de4f68e29b8331bd2a.tar.gz spark-0982572519655354b10987de4f68e29b8331bd2a.tar.bz2 spark-0982572519655354b10987de4f68e29b8331bd2a.zip |
Add methods called just 'accumulator' for int/double in Java API
Diffstat (limited to 'core/src/test')
-rw-r--r-- | core/src/test/scala/spark/JavaAPISuite.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/test/scala/spark/JavaAPISuite.java b/core/src/test/scala/spark/JavaAPISuite.java index b99e790093..912f8de05d 100644 --- a/core/src/test/scala/spark/JavaAPISuite.java +++ b/core/src/test/scala/spark/JavaAPISuite.java @@ -586,7 +586,7 @@ public class JavaAPISuite implements Serializable { public void accumulators() { JavaRDD<Integer> rdd = sc.parallelize(Arrays.asList(1, 2, 3, 4, 5)); - final Accumulator<Integer> intAccum = sc.intAccumulator(10); + final Accumulator<Integer> intAccum = sc.accumulator(10); rdd.foreach(new VoidFunction<Integer>() { public void call(Integer x) { intAccum.add(x); @@ -594,7 +594,7 @@ public class JavaAPISuite implements Serializable { }); Assert.assertEquals((Integer) 25, intAccum.value()); - final Accumulator<Double> doubleAccum = sc.doubleAccumulator(10.0); + final Accumulator<Double> doubleAccum = sc.accumulator(10.0); rdd.foreach(new VoidFunction<Integer>() { public void call(Integer x) { doubleAccum.add((double) x); |