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 [email protected] < [email protected]> 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. > > > [email protected] >
