0 
case class DataItem(name: String, timestamp: Long, value: String)
val dataitems = List(DataItem(SpindleSpeed, 1223334444, 20.3333),
                     DataItem(SpindleSpeed, 1223334450, 21.3333),
                     DataItem(SpindleSpeed, 1223334460, 19.3333),
                     DataItem(Load, 1223334444, 70.0023),
                     DataItem(Load, 1223334446, 72.0023),
                     DataItem(Pressure, 1223334444, 20.3333))

我有一个有点像这样的列表，我需要过滤掉最低的数据项timestamp。可以有多个日期项具有相同的时间戳，在这种情况下，我需要所有这些数据项。

在上述情况下，我希望过滤后的列表是，

List(DataItem(SpindleSpeed, 1223334444, 20.3333),
     DataItem(Load, 1223334444, 70.0023),
     DataItem(Pressure, 1223334444, 20.3333))

这样做的功能性方式是什么？我尝试对列表进行排序并返回头部。但这只会返回一个似乎不正确的数据项。

4

2 回答 2

4 
scala> val SpindleSpeed = "S"
SpindleSpeed: java.lang.String = S

scala> val Pressure = "P"
Pressure: java.lang.String = P

scala> val Load = "L"
Load: java.lang.String = L

scala> case class DataItem(name: String, timestamp: Long, value: Double)
defined class DataItem

scala> val dataitems = List(DataItem(SpindleSpeed, 1223334444, 20.3333),
     |                      DataItem(SpindleSpeed, 1223334450, 21.3333),
     |                      DataItem(SpindleSpeed, 1223334460, 19.3333),
     |                      DataItem(Load, 1223334444, 70.0023),
     |                      DataItem(Load, 1223334446, 72.0023),
     |                      DataItem(Pressure, 1223334444, 20.3333))
dataitems: List[DataItem] = List(DataItem(S,1223334444,20.3333), DataItem(S,1223334450,21.3333), DataItem(S,1223334460,19.3333), DataItem(L,1223334444,70.0023), DataItem(L,1223334446,72.0023), DataItem(P,1223334444,20.3333))

scala> dataitems.groupBy(_.timestamp).minBy(_._1)._2
res2: List[DataItem] = List(DataItem(S,1223334444,20.3333), DataItem(L,1223334444,70.0023), DataItem(P,1223334444,20.3333))

scala>
于 2012-10-06T17:41:49.370 回答
3

分两遍很容易做到：

val least = dataitems.minBy(_.timestamp).timestamp
val smalls = dataitems.filter(_.timestamp == least)

一次性完成它不那么有趣：

(List[DataItem]() /: dataitems){ (xs,x) => xs match {
  case Nil => x :: Nil
  case x0 :: more =>
    if (x0.timestamp < x.timestamp) xs
    else if (x0.timestamp > x.timestamp) x :: Nil
    else x :: x0
}}

这些都比按时间戳分组所有内容然后将除第一个之外的所有内容都扔掉更有效。

于 2012-10-06T18:38:50.077 回答