Flink如果是 SELECT COUNTflink sql 如何去重?如果不把之前的存储下来,是如[阿里云实时计算 Flink版]

Flink如果是 SELECT COUNT( DISTINCT orderId) FROM source_table;比较好奇,如果第一条数据的 orderId是 A00023,然后kafka推送到第 70W,条数据 的orderId 也是 A00023,flink sql 如何去重?如果不把之前的存储下来,是如何做到 过滤掉 A00023 这个重复 orderId的?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====