aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorJosh Rosen <rosenville@gmail.com>2012-07-25 10:11:34 -0700
committerJosh Rosen <rosenville@gmail.com>2012-07-25 10:13:06 -0700
commit2a60c998cc9ca8b9a90d8c7865f7494963395b3b (patch)
tree8aeb21af20f270c2e8302b82e766518c38f27731 /examples
parent6a78e88237cd2d2947cf5461e9da8359a16a0228 (diff)
downloadspark-2a60c998cc9ca8b9a90d8c7865f7494963395b3b.tar.gz
spark-2a60c998cc9ca8b9a90d8c7865f7494963395b3b.tar.bz2
spark-2a60c998cc9ca8b9a90d8c7865f7494963395b3b.zip
Remove StringOps.split() from Java WordCount.
Diffstat (limited to 'examples')
-rw-r--r--examples/src/main/java/spark/examples/JavaWordCount.java7
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);
}