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 刘医生 <ea...@gmail.com> on 2021/03/22 06:53:29 UTC

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

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