summaryrefslogtreecommitdiff
path: root/site
diff options
context:
space:
mode:
authorMatei Alexandru Zaharia <matei@apache.org>2014-04-19 04:50:46 +0000
committerMatei Alexandru Zaharia <matei@apache.org>2014-04-19 04:50:46 +0000
commit285def76f7a85939fef4dd2aaa39b21d661141f3 (patch)
treec22fd9e5399156ccf821490f413a4d736f789a4c /site
parentf848dad94491c7340e8d72a1e1e90a514a2d0ebc (diff)
downloadspark-website-285def76f7a85939fef4dd2aaa39b21d661141f3.tar.gz
spark-website-285def76f7a85939fef4dd2aaa39b21d661141f3.tar.bz2
spark-website-285def76f7a85939fef4dd2aaa39b21d661141f3.zip
Fix typo in example
Diffstat (limited to 'site')
-rw-r--r--site/examples.html6
1 files changed, 3 insertions, 3 deletions
diff --git a/site/examples.html b/site/examples.html
index 5cc8be1a2..3ae9afb79 100644
--- a/site/examples.html
+++ b/site/examples.html
@@ -272,13 +272,13 @@ previous ones, and <em>actions</em>, which kick off a job to execute on a cluste
<div class="tab-pane tab-pane-java">
<div class="code code-tab">
JavaRDD&lt;String&gt; file = spark.textFile(<span class="string">"hdfs://..."</span>);<br />
- JavaRDD&lt;String&gt; words = file.<span class="sparkop">flatMap</span>(<span class="closure">new FlatMapFunction&lt;String, String&gt;()<br />
+ 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">map</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 />
+ JavaPairRDD&lt;String, Integer&gt; counts = pairs.<span class="sparkop">reduceByKey</span>(<span class="closure">new Function2&lt;Integer, Integer&gt;() {<br />
&nbsp;&nbsp;public Integer call(Integer a, Integer b) { return a + b; }<br />
}</span>);<br />
counts.<span class="sparkop">saveAsTextFile</span>(<span class="string">"hdfs://..."</span>);