减少 scala（不是 Spark）

Question

我有这个数据：

(15,ArrayBuffer((1038,1)))
(14,ArrayBuffer((1031,1), (1003,1)))
(110,ArrayBuffer((1035,1))

所以Group和Map已经被执行了。现在我必须做一个减少步骤，我想要的结果是：

(15,1)
(14,2)
(110,1)

a简单算一下map-reduce。但是我不能写一个减少步骤（我必须在数组缓冲区中写任何 1 项 -dummy- 的总和）

Answer 1

您好，您可以使用地图和 ArrayBuffer 的大小

import scala.collection.mutable._ 

Seq((15,ArrayBuffer((1038,1)))
     ,(14,ArrayBuffer((1031,1),(1003,1)))
     ,(110,ArrayBuffer((1035,1))))
  .map { case (x,y) => (x,y.size) }

res2: scala.collection.mutable.Seq[(Int, Int)] = ArrayBuffer((15,1), (14,2), (110,1))

减少 scala（不是 Spark）

Reduce in scala (not Spark)

scala

mapreduce

sbt