From 1808465855a8e2ce554b024ad5ff530457584aed Mon Sep 17 00:00:00 2001 From: Dongjoon Hyun Date: Sat, 26 Mar 2016 11:55:49 +0000 Subject: [MINOR] Fix newly added java-lint errors ## What changes were proposed in this pull request? This PR fixes some newly added java-lint errors(unused-imports, line-lengsth). ## How was this patch tested? Pass the Jenkins tests. Author: Dongjoon Hyun Closes #11968 from dongjoon-hyun/SPARK-14167. --- .../org/apache/spark/sql/JavaDatasetSuite.java | 28 ++++++++++++---------- 1 file changed, 16 insertions(+), 12 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 86db8df4c0..a6c819373b 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 @@ -169,12 +169,14 @@ public class JavaDatasetSuite implements Serializable { public void testGroupBy() { List data = Arrays.asList("a", "foo", "bar"); Dataset ds = context.createDataset(data, Encoders.STRING()); - KeyValueGroupedDataset grouped = ds.groupByKey(new MapFunction() { - @Override - public Integer call(String v) throws Exception { - return v.length(); - } - }, Encoders.INT()); + KeyValueGroupedDataset grouped = ds.groupByKey( + new MapFunction() { + @Override + public Integer call(String v) throws Exception { + return v.length(); + } + }, + Encoders.INT()); Dataset mapped = grouped.mapGroups(new MapGroupsFunction() { @Override @@ -217,12 +219,14 @@ public class JavaDatasetSuite implements Serializable { List data2 = Arrays.asList(2, 6, 10); Dataset ds2 = context.createDataset(data2, Encoders.INT()); - KeyValueGroupedDataset grouped2 = ds2.groupByKey(new MapFunction() { - @Override - public Integer call(Integer v) throws Exception { - return v / 2; - } - }, Encoders.INT()); + KeyValueGroupedDataset grouped2 = ds2.groupByKey( + new MapFunction() { + @Override + public Integer call(Integer v) throws Exception { + return v / 2; + } + }, + Encoders.INT()); Dataset cogrouped = grouped.cogroup( grouped2, -- cgit v1.2.3