这是我使用map编写的scala代码,我需要使用mapPartitions编写这2行代码。数据在底部。
val deckofcardsRDD=sc.textFile("/user/root/decks/deckofcards.txt")
deckofcardsRDD.map(card => card.split("\\|")(2)).countByValue().toList.sortBy(_._1).foreach(println)输出
(2,4) (3,4) (4,4) (5,4)
数据
黑色球杆2黑心2红心2红心2红心4红心2红钻4红钻4红钻4红钻4红钻4红钻4红钻4红钻4红钻4红钻4红钻4红钻4红钻
发布于 2015-12-10 06:47:47
我能想出答案。
这是代码片段。
val deckofcardsRDD=sc.textFile("/user/root/decks/deckofcards.txt", 13)
deckofcardsRDD.mapPartitions(card => card.map(item => item.split("\\|")(2))).countByValue().toList.sortBy(_._1).foreach(println)https://stackoverflow.com/questions/34195164
复制相似问题