about flink calcite implement

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.


[hidden email]

[Kurt Young]

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