diff options
author | Sean R. Owen <srowen@apache.org> | 2015-06-03 17:14:40 +0000 |
---|---|---|
committer | Sean R. Owen <srowen@apache.org> | 2015-06-03 17:14:40 +0000 |
commit | 303c247e4604098518acaa2d8ebe63fc891706f0 (patch) | |
tree | a9e2161816b5ca47eaf33e14f662d89d40a9c70d /examples.md | |
parent | c7d6505310366ed7b3cfbf6a09cd5c1948313f4d (diff) | |
download | spark-website-303c247e4604098518acaa2d8ebe63fc891706f0.tar.gz spark-website-303c247e4604098518acaa2d8ebe63fc891706f0.tar.bz2 spark-website-303c247e4604098518acaa2d8ebe63fc891706f0.zip |
Fix two Java example typos
Diffstat (limited to 'examples.md')
-rw-r--r-- | examples.md | 4 |
1 files changed, 2 insertions, 2 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<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> + JavaPairRDD<String, Integer> counts = pairs.<span class="sparkop">reduceByKey</span>(<span class="closure">new Function2<Integer, 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>); @@ -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<Integer, Boolean>() {<br> - public Integer call(Integer i) {<br> + public Boolean call(Integer i) {<br> double x = Math.random();<br> double y = Math.random();<br> return x*x + y*y < 1;<br> |