rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-09-22 05:05:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: omit unused typed statistics helper from backport

Browse Source 
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
(cherry picked from commit 2f7dbd2168)
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
This commit is contained in:
discord9
2026-09-14 14:30:01 +08:00
parent da14ee21cf
commit 371a451475
1 changed files with 7 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/mito2/src/sst/parquet/format.rs
+7 -18
View File
@@ -36,7 +36,7 @@ use datafusion_common::ScalarValue;
use datatypes::arrow::array::{
ArrayRef, BinaryArray, BinaryDictionaryBuilder, DictionaryArray, UInt64Array,
};
use datatypes::arrow::datatypes::{DataType as ArrowDataType, SchemaRef, UInt32Type};
use datatypes::arrow::datatypes::{SchemaRef, UInt32Type};
use datatypes::arrow::record_batch::RecordBatch;
use datatypes::prelude::DataType;
use datatypes::types::json_type::JsonNativeType;
@@ -136,26 +136,15 @@ pub(crate) fn column_values(
column: &ColumnMetadata,
column_index: usize,
is_min: bool,
) -> Option<ArrayRef> {
column_values_by_type(
row_groups,
&column.column_schema.data_type.as_arrow_type(),
column_index,
is_min,
)
}
/// Returns min/max values for a top-level column with the given Arrow data type.
/// Resolves its leaf from the actual Parquet schema, not an inferred Arrow layout.
pub(crate) fn column_values_by_type(
row_groups: &[impl Borrow<RowGroupMetaData>],
data_type: &ArrowDataType,
column_index: usize,
is_min: bool,
) -> Option<ArrayRef> {
let column_index =
scalar_leaf_index(row_groups.first()?.borrow().schema_descr(), column_index)?;
let null_scalar: ScalarValue = data_type.try_into().ok()?;
let null_scalar: ScalarValue = column
.column_schema
.data_type
.as_arrow_type()
.try_into()
.ok()?;
let scalar_values = row_groups
.iter()
.map(|meta| {