This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
from fdaa32608b feat: impl Any for MemoryPool (#21803)
add 12bd5b0765 mem: Cleanup resources of done streams immediately (#22064)
No new revisions were added by this update.
Summary of changes:
.../physical-plan/src/aggregates/no_grouping.rs | 4 ++
.../physical-plan/src/aggregates/row_hash.rs | 10 ++++
.../physical-plan/src/aggregates/topk_stream.rs | 4 ++
datafusion/physical-plan/src/analyze.rs | 1 +
datafusion/physical-plan/src/async_func.rs | 6 ++-
datafusion/physical-plan/src/coalesce_batches.rs | 6 +++
datafusion/physical-plan/src/filter.rs | 8 ++++
datafusion/physical-plan/src/joins/cross_join.rs | 8 +++-
.../physical-plan/src/joins/hash_join/stream.rs | 6 +++
.../physical-plan/src/joins/nested_loop_join.rs | 6 +++
.../src/joins/piecewise_merge_join/classic_join.rs | 4 ++
.../src/joins/sort_merge_join/bitwise_stream.rs | 16 +++++--
.../joins/sort_merge_join/materializing_stream.rs | 14 ++++++
.../physical-plan/src/joins/symmetric_hash_join.rs | 18 ++++++++
datafusion/physical-plan/src/repartition/mod.rs | 8 +++-
datafusion/physical-plan/src/sorts/partial_sort.rs | 7 +++
.../physical-plan/src/sorts/partitioned_topk.rs | 2 +
datafusion/physical-plan/src/sorts/sort.rs | 2 +
.../src/spill/replayable_spill_input.rs | 3 ++
datafusion/physical-plan/src/stream.rs | 53 ++++++++++++++++++++--
datafusion/physical-plan/src/unnest.rs | 10 ++++
.../src/windows/bounded_window_agg_exec.rs | 5 ++
.../physical-plan/src/windows/window_agg_exec.rs | 5 ++
23 files changed, 194 insertions(+), 12 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
