关于Starrocks的Flink的connector的一点疑问

最近在看SR的Flink的connector的源码,关于支持维表join的代码,提供的是:
StarRocksDynamicLookupFunction


为什么获取执行计划的时候,不带上需要读取的列,以及where条件呢?

而是要查询全量数据,然后最后在查询结果返回到flink这端的时候再过滤?
希望有大佬解释一二。

维表功能有一些代码了,但是目前还不完善,没有发布过,你提到的是一个可以优化的点

大佬,为什么StarRocksSourceBeReader在读取完不close掉呢?是不是应该加上close呢?