summaryrefslogtreecommitdiff
path: root/examples.md
diff options
context:
space:
mode:
Diffstat (limited to 'examples.md')
-rw-r--r--examples.md2
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&lt;String&gt; words = file.<span class="sparkop">flatMap</span>(<span class="closure">new FlatMapFunction&lt;String, String&gt;() {<br>
&nbsp;&nbsp;public Iterable&lt;String&gt; call(String s) { return Arrays.asList(s.split(" ")); }<br>
}</span>);<br>
- JavaPairRDD&lt;String, Integer&gt; pairs = words.<span class="sparkop">map</span>(<span class="closure">new PairFunction&lt;String, String, Integer&gt;() {<br>
+ JavaPairRDD&lt;String, Integer&gt; pairs = words.<span class="sparkop">mapToPair</span>(<span class="closure">new PairFunction&lt;String, String, Integer&gt;() {<br>
&nbsp;&nbsp;public Tuple2&lt;String, Integer&gt; call(String s) { return new Tuple2&lt;String, Integer&gt;(s, 1); }<br>
}</span>);<br>
JavaPairRDD&lt;String, Integer&gt; counts = pairs.<span class="sparkop">reduceByKey</span>(<span class="closure">new Function2&lt;Integer, Integer&gt;() {<br>