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]
