我有四件事
UserEvent(id = "customer-1", lat = 1.0 , lng = 0.0 , ts = "2018-10-16T00:00:00.01Z"),
UserEvent(id = "customer-1", lat = 2.0 , lng = 0.0 , ts = "2018-10-16T03:00:00.01Z"),
UserEvent(id = "customer-1", lat = 3.0 , lng = 0.0, ts = "2018-10-16T04:00:00.01Z"),
UserEvent(id = "customer-1", lat = 4.0 , lng = 0.0 , ts = "2018-10-16T06:00:00.01Z")
我需要输出为
UserEvent(id = "customer-1", lat = 2.0 , lng = 0.0 , ts = "2018-10-16T03:00:00.01Z")
UserEvent(id = "customer-1", lat = 4.0 , lng = 0.0 , ts = "2018-10-16T06:00:00.01Z")
总而言之,我需要在 four hour
Windows。所有事件都由 id
.
我的解决方案是使用 KeyedProcessFunction
. 我的程序只发出最后一条记录,如下所示。
UserEvent(id = "customer-1", lat = 4.0 , lng = 0.0 , ts = "2018-10-16T06:00:00.01Z")
完整的单元测试可以在这里找到
1条答案
按热度按时间xdnvmnnf1#
从单元测试来看,似乎您打算使用事件时间,但要实现这一点,您应该使用
此外,你的问题是什么?