-
Notifications
You must be signed in to change notification settings - Fork 1.8k
Open
Feature
Copy link
Labels
enhancementNew feature or requestNew feature or request
Description
Is your feature request related to a problem or challenge?
The LimitedBatchCoalescer can now be used to integrate batch coalescing directly in ExecutionPlan implementations, which is better than using an external operator for the reasons described on #18779
Currently HashJoinExec needs a CoalesceBatches operator after for performance, see
| let wrap_in_coalesce = plan_any.downcast_ref::<HashJoinExec>().is_some() |
We should integrate coalescing directly in the operator
Describe the solution you'd like
- Add batch coalescing into HashJoinExec
- Remove HashJoinExec from the
CoalesceBatchesoptimizer rule:let wrap_in_coalesce = plan_any.downcast_ref::<HashJoinExec>().is_some()
Describe alternatives you've considered
@Dandandan did this for FilterExec in these two PRs, so we can probably follow a similar model
- Coalesce batches inside FilterExec #18604
- Remove FilterExec from CoalesceBatches optimization rule, add fetch support #18630
Additional context
No response
Metadata
Metadata
Assignees
Labels
enhancementNew feature or requestNew feature or request