Flink will convert all projections and filters to calc before converting to logical nodes. You can check out FlinkStreamRuleSets.LOGICAL_RULES
Best, Kurt On Mon, Jan 25, 2021 at 11:03 AM laughing.sh...@qq.com < laughing.sh...@qq.com> wrote: > > In flink table planner module, I can not find the rule that convert > calcite Filter or LogicalFilter into flink physicalNode. how flink > implement the filter operator. Is there any class like DataStreamScan that > implement the TableScan. > > > laughing.sh...@qq.com >
