adriangb commented on code in PR #17197:
URL: https://github.com/apache/datafusion/pull/17197#discussion_r2288519539
##########
datafusion/physical-plan/src/joins/hash_join.rs:
##########
@@ -365,7 +514,10 @@ pub struct HashJoinExec {
/// Cache holding plan properties like equivalences, output partitioning
etc.
cache: PlanProperties,
/// Dynamic filter for pushing down to the probe side
- dynamic_filter: Option<Arc<DynamicFilterPhysicalExpr>>,
+ dynamic_filter: Arc<DynamicFilterPhysicalExpr>,
+ /// Shared bounds accumulator for coordinating dynamic filter updates
across partitions
+ /// Lazily initialized at execution time to use actual runtime partition
counts
+ bounds_accumulator: Arc<OnceLock<Arc<SharedBoundsAccumulator>>>,
Review Comment:
I've refactored this away 😄
--
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: github-unsubscr...@datafusion.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org
For additional commands, e-mail: github-h...@datafusion.apache.org
