From f51dfe616b24b4234199c98ea857a586a93a889f Mon Sep 17 00:00:00 2001 From: Sean Owen Date: Sun, 12 Jun 2016 11:44:33 -0700 Subject: [SPARK-15086][CORE][STREAMING] Deprecate old Java accumulator API ## What changes were proposed in this pull request? - Deprecate old Java accumulator API; should use Scala now - Update Java tests and examples - Don't bother testing old accumulator API in Java 8 (too) - (fix a misspelling too) ## How was this patch tested? Jenkins tests Author: Sean Owen Closes #13606 from srowen/SPARK-15086. --- .../src/test/java/test/org/apache/spark/sql/JavaDatasetSuite.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'sql/core/src/test/java') diff --git a/sql/core/src/test/java/test/org/apache/spark/sql/JavaDatasetSuite.java b/sql/core/src/test/java/test/org/apache/spark/sql/JavaDatasetSuite.java index 37577accfd..a711811f41 100644 --- a/sql/core/src/test/java/test/org/apache/spark/sql/JavaDatasetSuite.java +++ b/sql/core/src/test/java/test/org/apache/spark/sql/JavaDatasetSuite.java @@ -32,7 +32,6 @@ import com.google.common.base.Objects; import org.junit.*; import org.junit.rules.ExpectedException; -import org.apache.spark.Accumulator; import org.apache.spark.api.java.JavaSparkContext; import org.apache.spark.api.java.function.*; import org.apache.spark.sql.*; @@ -40,6 +39,7 @@ import org.apache.spark.sql.catalyst.encoders.OuterScopes; import org.apache.spark.sql.catalyst.expressions.GenericRow; import org.apache.spark.sql.test.TestSparkSession; import org.apache.spark.sql.types.StructType; +import org.apache.spark.util.LongAccumulator; import static org.apache.spark.sql.functions.col; import static org.apache.spark.sql.functions.expr; import static org.apache.spark.sql.types.DataTypes.*; @@ -157,7 +157,7 @@ public class JavaDatasetSuite implements Serializable { @Test public void testForeach() { - final Accumulator accum = jsc.accumulator(0); + final LongAccumulator accum = jsc.sc().longAccumulator(); List data = Arrays.asList("a", "b", "c"); Dataset ds = spark.createDataset(data, Encoders.STRING()); -- cgit v1.2.3