aboutsummaryrefslogtreecommitdiff
path: root/core/src/test
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2013-01-05 22:11:28 -0500
committerMatei Zaharia <matei@eecs.berkeley.edu>2013-01-05 22:11:28 -0500
commit0982572519655354b10987de4f68e29b8331bd2a (patch)
tree53afe208eef9b888a9874d25fed4f2de3b786ea9 /core/src/test
parent86af64b0a6fde5a6418727a77b43bdfeda1b81cd (diff)
downloadspark-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.java4
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);