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 laughing.sh...@qq.com <
laughing.sh...@qq.com> wrote:
>
> In flink table planner module, I can not find the
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
