Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
请教Flink中关于窗口的问题
Classic
List
Threaded
♦
♦
Locked
1 message
syumialiu
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
请教Flink中关于窗口的问题
我在一个job中有一些很大的数据(key的种类很少,但是单个key下的数据数量很多),基本要实现的是一个时间滑动窗口结束时,当某个key的数量大于一个固定值后,将该key下的所有原数据输出。我现在的方法是将key加后缀,然后keyBy做窗口,但是这个做完之后还是需要再次keyBy把数据还原回去,并且这个过程又将全量数据拉到了一个节点上,请问有没有一些别的解决方法?
| |
syumialiu
|
|
[hidden email]
|
签名由网易邮箱大师定制
Free forum by Nabble
Edit this page