You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2014/04/19 06:50:47 UTC
svn commit: r1588608 - in /spark: examples.md site/examples.html
Author: matei
Date: Sat Apr 19 04:50:46 2014
New Revision: 1588608
URL: http://svn.apache.org/r1588608
Log:
Fix typo in example
Modified:
spark/examples.md
spark/site/examples.html
Modified: spark/examples.md
URL: http://svn.apache.org/viewvc/spark/examples.md?rev=1588608&r1=1588607&r2=1588608&view=diff
==============================================================================
--- spark/examples.md (original)
+++ spark/examples.md Sat Apr 19 04:50:46 2014
@@ -122,13 +122,13 @@ In this example, we search through the e
<div class="tab-pane tab-pane-java">
<div class="code code-tab">
JavaRDD<String> file = spark.textFile(<span class="string">"hdfs://..."</span>);<br>
- JavaRDD<String> words = file.<span class="sparkop">flatMap</span>(<span class="closure">new FlatMapFunction<String, String>()<br>
+ JavaRDD<String> words = file.<span class="sparkop">flatMap</span>(<span class="closure">new FlatMapFunction<String, String>() {<br>
public Iterable<String> call(String s) { return Arrays.asList(s.split(" ")); }<br>
}</span>);<br>
- JavaPairRDD<String, Integer> pairs = words.<span class="sparkop">map</span>(<span class="closure">new PairFunction<String, String, Integer>()<br>
+ JavaPairRDD<String, Integer> pairs = words.<span class="sparkop">map</span>(<span class="closure">new PairFunction<String, String, Integer>() {<br>
public Tuple2<String, Integer> call(String s) { return new Tuple2<String, Integer>(s, 1); }<br>
}</span>);<br>
- JavaPairRDD<String, Integer> counts = pairs.<span class="sparkop">reduceByKey</span>(<span class="closure">new Function2<Integer, Integer>()<br>
+ JavaPairRDD<String, Integer> counts = pairs.<span class="sparkop">reduceByKey</span>(<span class="closure">new Function2<Integer, Integer>() {<br>
public Integer call(Integer a, Integer b) { return a + b; }<br>
}</span>);<br>
counts.<span class="sparkop">saveAsTextFile</span>(<span class="string">"hdfs://..."</span>);
Modified: spark/site/examples.html
URL: http://svn.apache.org/viewvc/spark/site/examples.html?rev=1588608&r1=1588607&r2=1588608&view=diff
==============================================================================
--- spark/site/examples.html (original)
+++ spark/site/examples.html Sat Apr 19 04:50:46 2014
@@ -272,13 +272,13 @@ previous ones, and <em>actions</em>, whi
<div class="tab-pane tab-pane-java">
<div class="code code-tab">
JavaRDD<String> file = spark.textFile(<span class="string">"hdfs://..."</span>);<br />
- JavaRDD<String> words = file.<span class="sparkop">flatMap</span>(<span class="closure">new FlatMapFunction<String, String>()<br />
+ JavaRDD<String> words = file.<span class="sparkop">flatMap</span>(<span class="closure">new FlatMapFunction<String, String>() {<br />
public Iterable<String> call(String s) { return Arrays.asList(s.split(" ")); }<br />
}</span>);<br />
- JavaPairRDD<String, Integer> pairs = words.<span class="sparkop">map</span>(<span class="closure">new PairFunction<String, String, Integer>()<br />
+ JavaPairRDD<String, Integer> pairs = words.<span class="sparkop">map</span>(<span class="closure">new PairFunction<String, String, Integer>() {<br />
public Tuple2<String, Integer> call(String s) { return new Tuple2<String, Integer>(s, 1); }<br />
}</span>);<br />
- JavaPairRDD<String, Integer> counts = pairs.<span class="sparkop">reduceByKey</span>(<span class="closure">new Function2<Integer, Integer>()<br />
+ JavaPairRDD<String, Integer> counts = pairs.<span class="sparkop">reduceByKey</span>(<span class="closure">new Function2<Integer, Integer>() {<br />
public Integer call(Integer a, Integer b) { return a + b; }<br />
}</span>);<br />
counts.<span class="sparkop">saveAsTextFile</span>(<span class="string">"hdfs://..."</span>);