summaryrefslogtreecommitdiff
path: root/examples.md
diff options
context:
space:
mode:
authorSean R. Owen <srowen@apache.org>2015-06-03 17:14:40 +0000
committerSean R. Owen <srowen@apache.org>2015-06-03 17:14:40 +0000
commit303c247e4604098518acaa2d8ebe63fc891706f0 (patch)
treea9e2161816b5ca47eaf33e14f662d89d40a9c70d /examples.md
parentc7d6505310366ed7b3cfbf6a09cd5c1948313f4d (diff)
downloadspark-website-303c247e4604098518acaa2d8ebe63fc891706f0.tar.gz
spark-website-303c247e4604098518acaa2d8ebe63fc891706f0.tar.bz2
spark-website-303c247e4604098518acaa2d8ebe63fc891706f0.zip
Fix two Java example typos
Diffstat (limited to 'examples.md')
-rw-r--r--examples.md4
1 files changed, 2 insertions, 2 deletions
diff --git a/examples.md b/examples.md
index 18d869353..f7ad08f74 100644
--- a/examples.md
+++ b/examples.md
@@ -137,7 +137,7 @@ In this example, we search through the error messages in a log file:
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>
+ JavaPairRDD&lt;String, Integer&gt; counts = pairs.<span class="sparkop">reduceByKey</span>(<span class="closure">new Function2&lt;Integer, 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>);
@@ -178,7 +178,7 @@ In this example, we search through the error messages in a log file:
<div class="tab-pane tab-pane-java">
<div class="code code-tab">
<span class="keyword">int</span> count = spark.parallelize(makeRange(1, NUM_SAMPLES)).<span class="sparkop">filter</span>(<span class="closure">new Function&lt;Integer, Boolean&gt;() {<br>
- &nbsp;&nbsp;public Integer call(Integer i) {<br>
+ &nbsp;&nbsp;public Boolean call(Integer i) {<br>
&nbsp;&nbsp;&nbsp;&nbsp;double x = Math.random();<br>
&nbsp;&nbsp;&nbsp;&nbsp;double y = Math.random();<br>
&nbsp;&nbsp;&nbsp;&nbsp;return x*x + y*y &lt; 1;<br>