北牧kevin
北牧kevin_个人页
北牧kevin
文章
0
问答
2
视频
0
个人介绍
暂无个人介绍
擅长的技术
暂无更多信息
暂无更多信息
-
回答了问题
2019-07-17
Flink中KeyBy导致Re-distributing吗？
下面那个图中的两个map的圈是map的两个并发，那个keyby也是并发，一个map的并发是可以输出数据给多个下游的并发的
赞0 踩0 评论0 -
回答了问题
2019-07-17
flink如何计算设备离网
这个用session window应该可以解决。通过设备ID作key用keyby把同一个设备的数据放到一起，然后用session window，比如设置session超时时间15分钟，那设备如果如果超过15分钟没有汇报，则这15分钟前和后的数据会被分在两个window里面，对于单个window中的数据可以自己实现个AggregateFunction来计算，求得这个window的最大时间戳和最小时间戳（可以返回一个Tuple），两个连续的session window之前的时间差，也就是后一个的最小时间戳减去前一个的最大时间戳，就可以作为设备的离网时间了。
不知道你的需求是不是这样。
赞1 踩0 评论0
滑动查看更多
暂无更多信息
