From e5f6d5697b43ac89a50fb791f4b284409e75b1f4 Mon Sep 17 00:00:00 2001
From: Patrick Wendell <pwendell@gmail.com>
Date: Thu, 24 Oct 2013 22:08:06 -0700
Subject: [PATCH] Spacing fix
---
core/src/test/scala/org/apache/spark/JavaAPISuite.java | 4 ++--
.../java/org/apache/spark/streaming/JavaAPISuite.java | 8 ++++----
2 files changed, 6 insertions(+), 6 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());
diff --git a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
index 391d7ba21d..9da8adda83 100644
--- a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
+++ b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
@@ -186,8 +186,8 @@ public class JavaAPISuite implements Serializable {
@Test
public void testRepartitionMorePartitions() {
List<List<Integer>> inputData = Arrays.asList(
- Arrays.asList(1,2,3,4,5,6,7,8,9,10),
- Arrays.asList(1,2,3,4,5,6,7,8,9,10));
+ Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10),
+ Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10));
JavaDStream stream = JavaTestUtils.attachTestInputStream(ssc, inputData, 2);
JavaDStream repartitioned = stream.repartition(4);
JavaTestUtils.attachTestOutputStream(repartitioned);
@@ -203,8 +203,8 @@ public class JavaAPISuite implements Serializable {
@Test
public void testRepartitionFewerPartitions() {
List<List<Integer>> inputData = Arrays.asList(
- Arrays.asList(1,2,3,4,5,6,7,8,9,10),
- Arrays.asList(1,2,3,4,5,6,7,8,9,10));
+ Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10),
+ Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10));
JavaDStream stream = JavaTestUtils.attachTestInputStream(ssc, inputData, 4);
JavaDStream repartitioned = stream.repartition(2);
JavaTestUtils.attachTestOutputStream(repartitioned);
--
GitLab