Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for ShuffledRDD (0.17 sec)

  1. docs/bigdata/README.md

    scala> val counts = file.flatMap(line => line.split(" ")).map(word => (word, 1)).reduceByKey(_ + _)
    counts: org.apache.spark.rdd.RDD[(String, Int)] = ShuffledRDD[4] at reduceByKey at <console>:25
    
    scala> counts.saveAsTextFile("s3a://testbucket/wordcount")
    ```
    
    Use one of the following approaches to view job output:
    
    View output in the Scala shell:
    
    ```
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
Back to top