最近在看SR的Flink的connector的源码,关于支持维表join的代码,提供的是:
StarRocksDynamicLookupFunction
为什么获取执行计划的时候,不带上需要读取的列,以及where条件呢?
而是要查询全量数据,然后最后在查询结果返回到flink这端的时候再过滤?
希望有大佬解释一二。
最近在看SR的Flink的connector的源码,关于支持维表join的代码,提供的是:
StarRocksDynamicLookupFunction
维表功能有一些代码了,但是目前还不完善,没有发布过,你提到的是一个可以优化的点