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
