aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorPatrick Wendell <pwendell@gmail.com>2013-10-24 22:08:06 -0700
committerPatrick Wendell <pwendell@gmail.com>2013-10-24 22:08:06 -0700
commite5f6d5697b43ac89a50fb791f4b284409e75b1f4 (patch)
treeeb30958b6d60714d80e7e75d7660c510ef1079a1 /core
parenta351fd4aeda7d137e4cece705e25b51d7634ca63 (diff)
downloadspark-e5f6d5697b43ac89a50fb791f4b284409e75b1f4.tar.gz
spark-e5f6d5697b43ac89a50fb791f4b284409e75b1f4.tar.bz2
spark-e5f6d5697b43ac89a50fb791f4b284409e75b1f4.zip
Spacing fix
Diffstat (limited to 'core')
-rw-r--r--core/src/test/scala/org/apache/spark/JavaAPISuite.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/test/scala/org/apache/spark/JavaAPISuite.java b/core/src/test/scala/org/apache/spark/JavaAPISuite.java
index f38c607d65..352036f182 100644
--- a/core/src/test/scala/org/apache/spark/JavaAPISuite.java
+++ b/core/src/test/scala/org/apache/spark/JavaAPISuite.java
@@ -475,7 +475,7 @@ public class JavaAPISuite implements Serializable {
@Test
public void repartition() {
// Shrinking number of partitions
- JavaRDD<Integer> in1 = sc.parallelize(Arrays.asList(1,2,3,4,5,6,7,8), 2);
+ JavaRDD<Integer> in1 = sc.parallelize(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8), 2);
JavaRDD<Integer> repartitioned1 = in1.repartition(4);
List<List<Integer>> result1 = repartitioned1.glom().collect();
Assert.assertEquals(4, result1.size());
@@ -484,7 +484,7 @@ public class JavaAPISuite implements Serializable {
}
// Growing number of partitions
- JavaRDD<Integer> in2 = sc.parallelize(Arrays.asList(1,2,3,4,5,6,7,8), 4);
+ JavaRDD<Integer> in2 = sc.parallelize(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8), 4);
JavaRDD<Integer> repartitioned2 = in2.repartition(2);
List<List<Integer>> result2 = repartitioned2.glom().collect();
Assert.assertEquals(2, result2.size());