You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by dh...@apache.org on 2023/06/28 19:15:12 UTC

[arrow-datafusion] branch extra_capacity created (now 2e6b0d3033)

This is an automated email from the ASF dual-hosted git repository.

dheres pushed a change to branch extra_capacity
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git


      at 2e6b0d3033 Add some more capacity to join hashmap

This branch includes the following new commits:

     new 2e6b0d3033 Add some more capacity to join hashmap

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[arrow-datafusion] 01/01: Add some more capacity to join hashmap

Posted by dh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

dheres pushed a commit to branch extra_capacity
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git

commit 2e6b0d303319c401d7ef811c2fa6202427a9ad40
Author: Daniƫl Heres <da...@coralogix.com>
AuthorDate: Wed Jun 28 21:15:01 2023 +0200

    Add some more capacity to join hashmap
---
 datafusion/core/src/physical_plan/joins/hash_join_utils.rs | 2 +-
 testing                                                    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/datafusion/core/src/physical_plan/joins/hash_join_utils.rs b/datafusion/core/src/physical_plan/joins/hash_join_utils.rs
index 1b9cbd543d..ad7804e27f 100644
--- a/datafusion/core/src/physical_plan/joins/hash_join_utils.rs
+++ b/datafusion/core/src/physical_plan/joins/hash_join_utils.rs
@@ -103,7 +103,7 @@ pub struct SymmetricJoinHashMap(pub RawTable<(u64, SmallVec<[u64; 1]>)>);
 impl JoinHashMap {
     pub(crate) fn with_capacity(capacity: usize) -> Self {
         JoinHashMap {
-            map: RawTable::with_capacity(capacity),
+            map: RawTable::with_capacity(capacity * 2),
             next: vec![0; capacity],
         }
     }
diff --git a/testing b/testing
index e81d0c6de3..5bab2f264a 160000
--- a/testing
+++ b/testing
@@ -1 +1 @@
-Subproject commit e81d0c6de35948b3be7984af8e00413b314cde6e
+Subproject commit 5bab2f264a23f5af68f69ea93d24ef1e8e77fc88