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

Reply via email to