Module df_optimizer 

Datafusion optimizer for flow plan

Structs

CheckGroupByRule 🔒

This rule check all group by exprs, and make sure they are also in select clause in a aggr query

FindColumn 🔒

Find all column names in a plan

Functions

apply_df_optimizer

check_group_by_analyzer 🔒

make sure everything in group by’s expr is in select

sql_to_flow_plan

To reuse existing code for parse sql, the sql is first parsed into a datafusion logical plan, then to a substrait plan, and finally to a flow plan.