我创建了一个滑动窗口,并希望递归地打包进入该窗口周期的所有元素,这就是代码块
.map(x => ((x.pickup.get.latitude, x.pickup.get.longitude), (x.dropoff.get.latitude, x.dropoff.get.longitude)))
.windowAll(SlidingEventTimeWindows.of(Time.minutes(10), Time.minutes(1)))
.fold(List[((Double, Double), (Double, Double))]) {(acc, v) => acc :+ ((v._1._1, v._1._2), (v._2._1, v._2._2))}
我希望创造一个 List
其中的元素 tuple
,但这不起作用。
我试过这个,效果很好:
val l2 : List[((Int, Int), (Int, Int))] = List(((1, 1), (2, 2)))
val newl2 = l2 :+ ((3, 3), (4, 4))
我该怎么做?非常感谢
1条答案
按热度按时间yxyvkwin1#
第一个论点
fold
函数必须是初始值,而不是类型。将最后一行更改为:应该会成功的。