refactor(query): refactor the join partition to reduce memory amplification (#18732)

* refactor(query): refactor the join partition to reduce memory amplification

* refactor(query): refactor the join partition to reduce memory amplification

* refactor(query): refactor the join partition to reduce memory amplification

* refactor(query): refactor the join partition to reduce memory amplification

* refactor(query): refactor the join partition to reduce memory amplification

* refactor(query): refactor the join partition to reduce memory amplification

Author: zhang2014

src/common/column/src/binary/builder.rs

@@ -228,6 +228,11 @@ impl BinaryColumnBuilder {
             self.commit_row();
         }
     }
+
+    pub fn reserve(&mut self, offset_additional: usize, data_additional: usize) {
+        self.offsets.reserve(offset_additional);
+        self.data.reserve(data_additional)
+    }
 }
 
 impl<P: AsRef<[u8]>> FromIterator<P> for BinaryColumnBuilder {

src/query/expression/src/kernels/mod.rs

@@ -19,6 +19,7 @@ mod group_by_hash;
 mod scatter;
 mod sort;
 mod sort_compare;
+mod stream_partition;
 mod take;
 mod take_chunks;
 mod take_compact;
@@ -32,6 +33,7 @@ pub use filter::SELECTIVITY_THRESHOLD;
 pub use group_by_hash::*;
 pub use sort::*;
 pub use sort_compare::*;
+pub use stream_partition::*;
 pub use take_chunks::*;
 pub use topk::*;
 pub use utils::*;