https://github.com/datafusion-contrib/datafusion-distributed/pull/636 and https://github.com/datafusion-contrib/datafusion-distributed/pull/637 implement merging for dynamic filters which are marked as complete, such as ones in joins. This issue tracks update forwarding for `AggregateExec` / `SortExec` which produce incremental updates and can continuously be forwarded to workers.
#636 and #637 implement merging for dynamic filters which are marked as complete, such as ones in joins.
This issue tracks update forwarding for
AggregateExec/SortExecwhich produce incremental updates and can continuously be forwarded to workers.