diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-02-11 09:20:37 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-02-11 10:03:37 -0800 |
| commit | 314d87a038d84c4ae9a6471ea19a5431153ea604 (patch) | |
| tree | 001550bf01d3a854e4071bdf6da799ba522d9f13 /streaming | |
| parent | f0b68c623c116540470e06967c1554855d16a500 (diff) | |
| download | spark-314d87a038d84c4ae9a6471ea19a5431153ea604.tar.gz spark-314d87a038d84c4ae9a6471ea19a5431153ea604.tar.bz2 spark-314d87a038d84c4ae9a6471ea19a5431153ea604.zip | |
Indentation fix
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/test/java/spark/streaming/JavaAPISuite.java | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/streaming/src/test/java/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/spark/streaming/JavaAPISuite.java index 26ac82b71a..4cf9d115ae 100644 --- a/streaming/src/test/java/spark/streaming/JavaAPISuite.java +++ b/streaming/src/test/java/spark/streaming/JavaAPISuite.java @@ -511,16 +511,16 @@ public class JavaAPISuite implements Serializable { List<List<Tuple2<String, Integer>>> inputData = stringIntKVStream; List<List<Tuple2<Integer, String>>> expected = Arrays.asList( - Arrays.asList( - new Tuple2<Integer, String>(1, "california"), - new Tuple2<Integer, String>(3, "california"), - new Tuple2<Integer, String>(4, "new york"), - new Tuple2<Integer, String>(1, "new york")), - Arrays.asList( - new Tuple2<Integer, String>(5, "california"), - new Tuple2<Integer, String>(5, "california"), - new Tuple2<Integer, String>(3, "new york"), - new Tuple2<Integer, String>(1, "new york"))); + Arrays.asList( + new Tuple2<Integer, String>(1, "california"), + new Tuple2<Integer, String>(3, "california"), + new Tuple2<Integer, String>(4, "new york"), + new Tuple2<Integer, String>(1, "new york")), + Arrays.asList( + new Tuple2<Integer, String>(5, "california"), + new Tuple2<Integer, String>(5, "california"), + new Tuple2<Integer, String>(3, "new york"), + new Tuple2<Integer, String>(1, "new york"))); JavaDStream<Tuple2<String, Integer>> stream = JavaTestUtils.attachTestInputStream(ssc, inputData, 1); JavaPairDStream<String, Integer> pairStream = JavaPairDStream.fromJavaDStream(stream); |