summaryrefslogtreecommitdiff
path: root/site
diff options
context:
space:
mode:
authorReynold Xin <rxin@apache.org>2014-11-27 00:35:46 +0000
committerReynold Xin <rxin@apache.org>2014-11-27 00:35:46 +0000
commitf6f6edc03e4578d6a86d47523bc2ba70d0910229 (patch)
tree3b9f180b1de05f44f57059508e50f0d27063ac9a /site
parent439eeb021dcb8891bcf0129fdc2e973ea2633833 (diff)
downloadspark-website-f6f6edc03e4578d6a86d47523bc2ba70d0910229.tar.gz
spark-website-f6f6edc03e4578d6a86d47523bc2ba70d0910229.tar.bz2
spark-website-f6f6edc03e4578d6a86d47523bc2ba70d0910229.zip
[SPARK-4046] Incorrect Java example on site
Diffstat (limited to 'site')
-rw-r--r--site/examples.html2
1 files changed, 1 insertions, 1 deletions
diff --git a/site/examples.html b/site/examples.html
index b31ea1c51..1bf74ad86 100644
--- a/site/examples.html
+++ b/site/examples.html
@@ -291,7 +291,7 @@ previous ones, and <em>actions</em>, which kick off a job to execute on a cluste
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 />