diff options
author | Patrick Wendell <pwendell@gmail.com> | 2013-10-24 22:08:06 -0700 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2013-10-24 22:08:06 -0700 |
commit | e5f6d5697b43ac89a50fb791f4b284409e75b1f4 (patch) | |
tree | eb30958b6d60714d80e7e75d7660c510ef1079a1 /streaming/src/test/java/org/apache | |
parent | a351fd4aeda7d137e4cece705e25b51d7634ca63 (diff) | |
download | spark-e5f6d5697b43ac89a50fb791f4b284409e75b1f4.tar.gz spark-e5f6d5697b43ac89a50fb791f4b284409e75b1f4.tar.bz2 spark-e5f6d5697b43ac89a50fb791f4b284409e75b1f4.zip |
Spacing fix
Diffstat (limited to 'streaming/src/test/java/org/apache')
-rw-r--r-- | streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java | 8 |
1 files changed, 4 insertions, 4 deletions
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); |