diff options
| author | Reynold Xin <rxin@apache.org> | 2014-11-27 00:35:46 +0000 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-11-27 00:35:46 +0000 |
| commit | f6f6edc03e4578d6a86d47523bc2ba70d0910229 (patch) | |
| tree | 3b9f180b1de05f44f57059508e50f0d27063ac9a | |
| parent | 439eeb021dcb8891bcf0129fdc2e973ea2633833 (diff) | |
| download | spark-website-f6f6edc03e4578d6a86d47523bc2ba70d0910229.tar.gz spark-website-f6f6edc03e4578d6a86d47523bc2ba70d0910229.tar.bz2 spark-website-f6f6edc03e4578d6a86d47523bc2ba70d0910229.zip | |
[SPARK-4046] Incorrect Java example on site
| -rw-r--r-- | examples.md | 2 | ||||
| -rw-r--r-- | site/examples.html | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/examples.md b/examples.md index 763ee7dfc..3658d1788 100644 --- a/examples.md +++ b/examples.md @@ -134,7 +134,7 @@ In this example, we search through the error messages in a log file: 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> 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 /> |