开发者社区 问答 正文

parse阶段已经做了filter,为什么sink阶段还要做filter

看了代码,发现parse阶段和sink阶段都有filter的逻辑,sink阶段的filter逻辑是否是没有必要的?

parse阶段:

ddl的过滤

提问286.png

dml的过滤

提问287.png

sink阶段:

提问288.png

实际测试了下,不相关的dml也确实不会走到sink阶段。

请问下sink阶段做filter是基于什么考虑?是否可以去掉sink阶段的filter逻辑。

原提问者GitHub用户gaoxiangyu

展开
收起
Java工程师 2023-05-08 17:37:14 88 分享 版权
1 条回答
写回答
取消 提交回答
  • 现在sink里的filter是NULL,没有启作用。

    早期设计的思路是为支持多client订阅不同表来做的,parser会解析多个client的共同条件,sink可以按照不同的用户filter提前分出多个store,所以会有两层filter的设计

    原回答者GitHub用户agapple

    2023-05-09 18:39:57
    赞同 展开评论
问答分类:
SQL
问答地址: