关于KafkaTableSourceBase未实现ProjectableTableSource接口的疑问

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

关于KafkaTableSourceBase未实现ProjectableTableSource接口的疑问

easonliu30624700
场景:使用了flink(版本 1.11.2 )的sql功能。
疑问:当前阅读flink源码,发现:KafkaTableSourceBase并没有实现ProjectableTableSource、
FilterableTableSource 接口?
目的:实现ProjectableTableSource接口,可以在source端对筛选出需要的字段。同样,实现FilterableTableSource接口,继续在sourcedaunt进行预过滤。
是否有其他原因,导致 KafkaTableSourceBase未能支持预过滤预筛选的功能。