-
Notifications
You must be signed in to change notification settings - Fork 94
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add PredicatePushdownOptimizer in tracking-only mode #1262
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM - excited to see this get used!
if len(node_semantic_models) != 1 or not current_pushdown_state.has_where_filters_to_push_down: | ||
return self._default_handler(node) | ||
|
||
source_semantic_model, *_ = node_semantic_models |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
TIL about *_
!!
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yeah that was mind-blowing. 🤯 🤣
ff2748f
to
8af1ba3
Compare
186d5f5
to
c6f8777
Compare
8af1ba3
to
eec446c
Compare
In order to run predicate pushdown in a more robust manner we would be better served applying it as a post-plan-building optimizer rather than a build-time injection of additional where constraints. This PR adds the optimizer class with full tracking of predicate pushdown state, but it simply returns all nodes in the input DataflowPlan without modifying anything, since the predicate pushdown is already applied in the DataflowPlanBuilder. Future updates will move both the where constraint and time range constraint pushdown operations into this optimizer class. For now we simply evaluate the output from console logs to get a basis for future implementation changes.
c6f8777
to
16ae775
Compare
In order to run predicate pushdown in a more robust manner we would
be better served applying it as a post-plan-building optimizer rather
than a build-time injection of additional where constraints.
This PR adds the optimizer class with full tracking of predicate
pushdown state, but it simply returns all nodes in the input
DataflowPlan without modifying anything, since the predicate pushdown
is already applied in the DataflowPlanBuilder.
Future updates will move both the where constraint and time range constraint
pushdown operations into this optimizer class. For now we simply evaluate
the output from console logs to get a basis for future implementation changes.