diff options
Diffstat (limited to 'index.md')
-rw-r--r-- | index.md | 8 |
1 files changed, 4 insertions, 4 deletions
@@ -54,11 +54,11 @@ navigation: <div class="code"> file = spark.textFile(<span class="string">"hdfs://..."</span>)<br/> <br/> - file.<span class="sparkop">flatMap</span>(<span class="closure">line => line.split(" ")</span>)<br/> - .<span class="sparkop">map</span>(<span class="closure">word => (word, 1)</span>)<br/> - .<span class="sparkop">reduceByKey</span>(<span class="closure">_ + _</span>) + file.<span class="sparkop">flatMap</span>(<span class="closure">lambda line: line.split()</span>)<br/> + .<span class="sparkop">map</span>(<span class="closure">lambda word: (word, 1)</span>)<br/> + .<span class="sparkop">reduceByKey</span>(<span class="closure">lambda a, b: a+b</span>) </div> - <div class="caption">Word count in Spark</div> + <div class="caption">Word count in Spark's Python API</div> </div> <!-- <div class="code" style="margin-top: 20px; text-align: left; display: inline-block;"> |