summaryrefslogtreecommitdiff
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
parentc7d6505310366ed7b3cfbf6a09cd5c1948313f4d (diff)
downloadspark-website-303c247e4604098518acaa2d8ebe63fc891706f0.tar.gz
spark-website-303c247e4604098518acaa2d8ebe63fc891706f0.tar.bz2
spark-website-303c247e4604098518acaa2d8ebe63fc891706f0.zip
Fix two Java example typos
-rw-r--r--examples.md4
-rw-r--r--site/examples.html4
2 files changed, 4 insertions, 4 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>
diff --git a/site/examples.html b/site/examples.html
index de491f2a8..c7a4f0cb7 100644
--- a/site/examples.html
+++ b/site/examples.html
@@ -297,7 +297,7 @@ previous ones, and <em>actions</em>, which kick off a job to execute on a cluste
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>);
@@ -338,7 +338,7 @@ 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">
<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 />