Hi Yiyun, IIUC, you are talking about "Runtime filter", right? I don't know any existing rule which is doing this for now. And I think this is more like a physical implementation, rather than a pure optimization during logical planning.
FYI, Apache Flink has a FLIP[1] that talks about this. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-248%3A+Introduce+dynamic+partition+pruning Yiyun Yin <[email protected]> 于2022年8月15日周一 12:01写道： > Dear, > Hello, I am Yiyun Yin. I am trying to develop a data federation query > service using calcite, and I have a question I would like to ask. > <https://stackoverflow.com/posts/73352781/timeline> > > When I use join query with calcite, how can I optimize the query plan > so that it can query the small table first, and then use the result of the > small table as the filter condition of the large table? > > I am looking forward for your answers. Thank you. > > > Best Regards, > Yours sincerely, > Yiyun Yin > -- Best, Benchao Li
