FlinkCDC的数据不支持窗口,这种要咋弄?[阿里云实时计算 Flink版]

FlinkCDC的数据不支持窗口,这种要咋弄?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. FlinkCDC的数据不支持窗口,但是可以使用Flink的ProcessFunction来实现窗口功能。ProcessFunction可以捕获流中的每个元素,并在每个元素上执行自定义的操作,从而实现窗口功能。

  2. cdc做数据同步,一般同步至ods层,然后再从ods出发做清洗、分层、计算啥的——该回答整理自钉群“【③群】Apache Flink China社区”