diff options
Diffstat (limited to 'examples.md')
-rw-r--r-- | examples.md | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples.md b/examples.md index 763ee7dfc..3658d1788 100644 --- a/examples.md +++ b/examples.md @@ -134,7 +134,7 @@ In this example, we search through the error messages in a log file: JavaRDD<String> words = file.<span class="sparkop">flatMap</span>(<span class="closure">new FlatMapFunction<String, String>() {<br> public Iterable<String> call(String s) { return Arrays.asList(s.split(" ")); }<br> }</span>);<br> - JavaPairRDD<String, Integer> pairs = words.<span class="sparkop">map</span>(<span class="closure">new PairFunction<String, String, Integer>() {<br> + JavaPairRDD<String, Integer> pairs = words.<span class="sparkop">mapToPair</span>(<span class="closure">new PairFunction<String, String, Integer>() {<br> public Tuple2<String, Integer> call(String s) { return new Tuple2<String, Integer>(s, 1); }<br> }</span>);<br> JavaPairRDD<String, Integer> counts = pairs.<span class="sparkop">reduceByKey</span>(<span class="closure">new Function2<Integer, Integer>() {<br> |