You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by jy l <lj...@gmail.com> on 2020/12/21 06:10:35 UTC

flink1.10.0中的filter下推还能在flink1.12.0中使用吗?

Hi:
我们在flink-1.10.0中自定义了connect,并实现类了FilterableTableSource接口。目前flink-1.12.0发布了,我们想将之前解析Expression放到新版本中来使用。但是发现之前解析的方式在新版本中不能使用了。
是新版本不再支持flink-1.10.0中的Expression解析方式了吗?还是之前的依旧可以用,只是我的打开方式不对,那在1.12.0中怎么解析Expression生成Or、EqualTo、LessThan等下推的Filter?




祝好!