对,肯定是按照窗口去重的。我就想问下,窗口去重时,所采用的方式
在 2019-09-04 14:38:29,"[email protected]" <[email protected]> 写道:
>在窗口内去重吧,不可能无限保留去重数据的
>
>
>
>[email protected]
> 
>发件人: lvwenyuan
>发送时间: 2019-09-04 14:28
>收件人: user-zh
>主题: 关于Flink SQL DISTINCT问题
>各位大佬好:
>       我想问下,关于flink sql的实时去重,就是count(distinct user_id) 
> 。就是Flink内部是如何做到实时去重,如果对于数据量比较大的时候实时去重,是否会有性能问题。用的Blink Planner

回复