diff options
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); |