From 2f9130a2dee400cd96d8a9dc9b63f008c9f2ac8e Mon Sep 17 00:00:00 2001 From: "Lei, HUANG" <6406592+v0y4g3r@users.noreply.github.com> Date: Tue, 9 Dec 2025 22:33:14 +0800 Subject: [PATCH] chore(mito): expose some symbols (#7373) chore/expose-symbols: ### Commit Summary - **Visibility Changes**: Updated visibility of functions in `bulk/part.rs`: - Made `record_batch_estimated_size` and `sort_primary_key_record_batch` functions public. - **Enhancements**: Enhanced functionality in `memtable.rs` by exposing additional components from `bulk::part`: - `BulkPartEncoder`, `BulkPartMeta`, `UnorderedPart`, `record_batch_estimated_size`, and `sort_primary_key_record_batch`. Signed-off-by: Lei, HUANG --- src/mito2/src/memtable.rs | 4 ++++ src/mito2/src/memtable/bulk/part.rs | 4 ++-- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/src/mito2/src/memtable.rs b/src/mito2/src/memtable.rs index ea3875ac7a..e95d5e348f 100644 --- a/src/mito2/src/memtable.rs +++ b/src/mito2/src/memtable.rs @@ -57,6 +57,10 @@ pub(crate) mod version; #[cfg(any(test, feature = "test"))] pub use bulk::part::BulkPart; +pub use bulk::part::{ + BulkPartEncoder, BulkPartMeta, UnorderedPart, record_batch_estimated_size, + sort_primary_key_record_batch, +}; #[cfg(any(test, feature = "test"))] pub use time_partition::filter_record_batch; diff --git a/src/mito2/src/memtable/bulk/part.rs b/src/mito2/src/memtable/bulk/part.rs index aa2278cb78..6aedf9a5d7 100644 --- a/src/mito2/src/memtable/bulk/part.rs +++ b/src/mito2/src/memtable/bulk/part.rs @@ -464,7 +464,7 @@ impl UnorderedPart { } /// More accurate estimation of the size of a record batch. -pub(crate) fn record_batch_estimated_size(batch: &RecordBatch) -> usize { +pub fn record_batch_estimated_size(batch: &RecordBatch) -> usize { batch .columns() .iter() @@ -715,7 +715,7 @@ fn new_primary_key_column_builders( } /// Sorts the record batch with primary key format. -fn sort_primary_key_record_batch(batch: &RecordBatch) -> Result { +pub fn sort_primary_key_record_batch(batch: &RecordBatch) -> Result { let total_columns = batch.num_columns(); let sort_columns = vec![ // Primary key column (ascending)