diff options
Diffstat (limited to 'site')
| -rw-r--r-- | site/examples.html | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/site/examples.html b/site/examples.html index b31ea1c51..1bf74ad86 100644 --- a/site/examples.html +++ b/site/examples.html @@ -291,7 +291,7 @@ previous ones, and <em>actions</em>, which kick off a job to execute on a cluste 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">mapToPair</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 /> |