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