You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2013/10/25 07:32:13 UTC
[3/5] git commit: Spacing fix
Spacing fix
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/e5f6d569
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/e5f6d569
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/e5f6d569
Branch: refs/heads/master
Commit: e5f6d5697b43ac89a50fb791f4b284409e75b1f4
Parents: a351fd4
Author: Patrick Wendell <pw...@gmail.com>
Authored: Thu Oct 24 22:08:06 2013 -0700
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Thu Oct 24 22:08:06 2013 -0700
----------------------------------------------------------------------
core/src/test/scala/org/apache/spark/JavaAPISuite.java | 4 ++--
.../test/java/org/apache/spark/streaming/JavaAPISuite.java | 8 ++++----
2 files changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/e5f6d569/core/src/test/scala/org/apache/spark/JavaAPISuite.java
----------------------------------------------------------------------
diff --git a/core/src/test/scala/org/apache/spark/JavaAPISuite.java b/core/src/test/scala/org/apache/spark/JavaAPISuite.java
index f38c607..352036f 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());
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/e5f6d569/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
----------------------------------------------------------------------
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 391d7ba..9da8add 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);