实现SupportsFilterPushDown接口过程中遇到的问题

Wed, 01 Jun 2022 05:04:54 -0700 

Hello Everyone
    
1. 我的目的是：使Flink Jdbc Connector支持谓词下推

2. 实现过程/背景：
        我修改了Flink Jdbc Connector的代码，使 JdbcDynamicTableSource 类实现了 
SupportsFilterPushDown 接口。
在SupportsFilterPushDown.applyFilters(List<ResolvedExpression> filters) 
方法中我解析了Expression并转换成了类似下面的过滤条件
https://gist.github.com/zhuyufeng0809/f7e715d5c083e9674190544b7c8ef70d 
<https://gist.github.com/zhuyufeng0809/f7e715d5c083e9674190544b7c8ef70d>。
然后想将过滤条件拼接到 JdbcDynamicTableSource. getScanRuntimeProvider 
方法中的SQL查询语句上，从而实现谓词下推。

3. 现在遇到的问题是：
        Flink Jdbc 
Connector运行时先调用的是getScanRuntimeProvider方法，后调用的是applyFilters方法。所以调用applyFilters方法生成过滤条件的时候，getScanRuntimeProvider方法已经被调用过了，无法再拼接过滤条件
        目前卡在这里，想请教各位大佬如何才能将过滤条件拼接上去
4. Flink版本：1.14.3

回复