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