DynamicTableSource中Filter push down

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

DynamicTableSource中Filter push down

automths
Hi:
各位大佬,请教一个问题。
我再flink-1.12.0上自定义一个DynamicTableSource,并支持SupportsFilterPushDown,SupportsProjectionPushDown等特性。
然后我的ScanRuntimeProvider使用的是InputFormatProvider。
我运行时,下推的filters在创建InputFormat和copy()方法之后,那我还怎么在InputFormat中根据filters去过滤数据源呢?


望知道的告知一下,感谢!
祝好!