Hi, 1. projection prune 可查看:CoreRules.PROJECT_REMOVE, FlinkLogicalCalcRemoveRule.INSTANCE 2. projection push into tablesource 可查看:PushProjectIntoTableSourceScanRule
Best, Hailong 在 2020-12-15 20:57:32,"SmileSmile" <a511955...@163.com> 写道: >hi,社区的各位,是否有了解flink sql的列裁剪的实现原理? > >通过calcite的rbo可以实现sql优化,calcite的coreRules好像没有实现列裁剪。看一些文章有提到flink有实现projection >pushdown。请问下这部分源码对应哪里 > >Best! > > >| | >a511955993 >| >| >邮箱:a511955...@163.com >| > >签名由 网易邮箱大师 定制