alamb commented on issue #16973: URL: https://github.com/apache/datafusion/issues/16973#issuecomment-3299082069
Here is the relevant code for pushing filters through joins in the logical optimizer. https://github.com/apache/datafusion/blob/0c7d8307a8c4f027d3e6b5c1b906c992a33a91b5/datafusion/optimizer/src/push_down_filter.rs#L431-L430 I think we coud implement similar rules in the physical plans Specifically this code for pushing filters through HashJoinExec: https://github.com/apache/datafusion/blob/49d49fd92dddf55bfb22787fea17dda1a698dc4d/datafusion/physical-plan/src/joins/hash_join/exec.rs#L1145-L1152 The pushdown flow is explained here https://github.com/apache/datafusion/blob/be3842b55d61095d77aae54426726ddd1eed5f2c/datafusion/physical-plan/src/execution_plan.rs#L594-L611 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
