diff --git a/src/mito2/src/memtable/bulk/part.rs b/src/mito2/src/memtable/bulk/part.rs index 68328961a2c0..89147abf1e8d 100644 --- a/src/mito2/src/memtable/bulk/part.rs +++ b/src/mito2/src/memtable/bulk/part.rs @@ -170,15 +170,6 @@ impl BulkPartEncoder { } } -/// Loads metadata. -fn load_metadata(buf: &Bytes) -> Result> { - let options = ArrowReaderOptions::new() - .with_page_index(true) - .with_skip_arrow_metadata(true); - let metadata = ArrowReaderMetadata::load(buf, options).context(error::ReadDataPartSnafu)?; - Ok(metadata.metadata().clone()) -} - /// Converts mutations to record batches. fn mutations_to_record_batch( mutations: &[Mutation], diff --git a/src/mito2/src/sst/parquet/row_group.rs b/src/mito2/src/sst/parquet/row_group.rs index 8738ed79358a..045f2a501068 100644 --- a/src/mito2/src/sst/parquet/row_group.rs +++ b/src/mito2/src/sst/parquet/row_group.rs @@ -156,6 +156,8 @@ impl<'a> RowGroupBase<'a> { .collect::>() } + /// Assigns uncompressed chunk binary data to [RowGroupBase::column_chunks] + /// and returns the chunk offset and binary data assigned. pub(crate) fn assign_dense_chunk( &mut self, projection: &ProjectionMask, diff --git a/src/mito2/src/sst/parquet/stats.rs b/src/mito2/src/sst/parquet/stats.rs index 2804551fce12..09b837698cf1 100644 --- a/src/mito2/src/sst/parquet/stats.rs +++ b/src/mito2/src/sst/parquet/stats.rs @@ -27,7 +27,7 @@ use store_api::storage::ColumnId; use crate::sst::parquet::format::ReadFormat; /// Statistics for pruning row groups. -pub struct RowGroupPruningStats<'a, T> { +pub(crate) struct RowGroupPruningStats<'a, T> { /// Metadata of SST row groups. row_groups: &'a [T], /// Helper to read the SST.