嗨如何改变这个
for (w <- m ){
val w = (w._2.collect {
case x if (x._2 > 0) => x._2;
case x if (x._2 < 0) => x._2 }) // if I add here .sum i got sum of (negative and positive) together
}
要在一个集合中获得正值的总和和负值的总和,它可以是 List(positive.sum,negative.sum) 或两个值
编辑:只有 groupby、slice、collect、sum 和 yield
我写了工作程序,但它没有被接受,因为它做了两个收集
val m = d.groupBy(_._1.slice(0, 7))
for (w<- m) {
val x = (w._2.collect { case x if (x._2> 0) => x._2 }).sum
val y = (w._2.collect { case x if (x._2< 0) => x._2 }).sum
println("%7s %11.2f %11.2f %11.2f" format(w._1 , x , y ,(x+y)))
}
}
输入数据是
val d = List(("2011-01-04", -137.76),
("2011-01-04", 2376.45),
("2011-01-04", -1.70),
("2011-01-04", -1.70),
("2011-01-04", -1.00),
("2011-01-06", 865.70),
("2011-01-07", -734.15),
("2011-01-05", -188.63),
("2011-01-06", -73.50),
("2011-01-07", -200.00),
("2011-01-09", -215.35),
("2011-01-09", -8.86),
("2011-01-09", -300.00),
("2011-01-11", -634.54),
("2011-01-11", -400.00),
("2011-01-12", -92.87),
("2011-01-13", -1839.24),
("2011-01-13", 10000.00),
("2011-01-13", -10000.00),
("2011-01-15", -127.97),
("2011-01-15", -319.02),
("2011-01-19", -549.00),
("2011-01-21", -164.80),
("2011-01-23", -500.00),
("2011-01-25", -377.97),
("2011-01-26", 2158.66),
("2011-01-26", -130.45),
("2011-01-27", -350.00),
("2011-01-29", -500.00),
("2011-02-01", 2376.45),
("2011-02-01", 955.00))