examples.html

rxin Wed, 26 Nov 2014 16:36:59 -0800

Author: rxin
Date: Thu Nov 27 00:35:46 2014
New Revision: 1641971

URL: http://svn.apache.org/r1641971
Log:
[SPARK-4046] Incorrect Java example on site


Modified:
    spark/examples.md
    spark/site/examples.html

Modified: spark/examples.md
URL: 
http://svn.apache.org/viewvc/spark/examples.md?rev=1641971&r1=1641970&r2=1641971&view=diff
==============================================================================
--- spark/examples.md (original)
+++ spark/examples.md Thu Nov 27 00:35:46 2014
@@ -134,7 +134,7 @@ In this example, we search through the e
     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>

Modified: spark/site/examples.html
URL: 
http://svn.apache.org/viewvc/spark/site/examples.html?rev=1641971&r1=1641970&r2=1641971&view=diff
==============================================================================
--- spark/site/examples.html (original)
+++ spark/site/examples.html Thu Nov 27 00:35:46 2014
@@ -291,7 +291,7 @@ previous ones, and <em>actions</em>, whi
     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 />



---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

svn commit: r1641971 - in /spark: examples.md site/examples.html

Reply via email to