diff options
author | Josh Rosen <rosenville@gmail.com> | 2012-07-25 10:11:34 -0700 |
---|---|---|
committer | Josh Rosen <rosenville@gmail.com> | 2012-07-25 10:13:06 -0700 |
commit | 2a60c998cc9ca8b9a90d8c7865f7494963395b3b (patch) | |
tree | 8aeb21af20f270c2e8302b82e766518c38f27731 /examples/src | |
parent | 6a78e88237cd2d2947cf5461e9da8359a16a0228 (diff) | |
download | spark-2a60c998cc9ca8b9a90d8c7865f7494963395b3b.tar.gz spark-2a60c998cc9ca8b9a90d8c7865f7494963395b3b.tar.bz2 spark-2a60c998cc9ca8b9a90d8c7865f7494963395b3b.zip |
Remove StringOps.split() from Java WordCount.
Diffstat (limited to 'examples/src')
-rw-r--r-- | examples/src/main/java/spark/examples/JavaWordCount.java | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/examples/src/main/java/spark/examples/JavaWordCount.java b/examples/src/main/java/spark/examples/JavaWordCount.java index 5164dfdd1d..fb2feec09d 100644 --- a/examples/src/main/java/spark/examples/JavaWordCount.java +++ b/examples/src/main/java/spark/examples/JavaWordCount.java @@ -1,7 +1,6 @@ package spark.examples; import scala.Tuple2; -import scala.collection.immutable.StringOps; import spark.api.java.JavaPairRDD; import spark.api.java.JavaRDD; import spark.api.java.JavaSparkContext; @@ -26,8 +25,7 @@ public class JavaWordCount { JavaPairRDD<String, Integer> counts = lines.flatMap(new FlatMapFunction<String, String>() { public Iterable<String> apply(String s) { - StringOps op = new StringOps(s); - return Arrays.asList(op.split(' ')); + return Arrays.asList(s.split(" ")); } }).map(new PairFunction<String, String, Integer>() { public Tuple2<String, Integer> apply(String s) { @@ -41,8 +39,7 @@ public class JavaWordCount { List<Tuple2<String, Integer>> output = counts.collect(); for (Tuple2 tuple : output) { - System.out.print(tuple._1 + ": "); - System.out.println(tuple._2); + System.out.println(tuple._1 + ": " + tuple._2); } System.exit(0); } |