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