vortex_array/arrays/extension/compute/
min_max.rs1use vortex_dtype::Nullability;
5use vortex_error::VortexResult;
6
7use crate::arrays::ExtensionArray;
8use crate::arrays::ExtensionVTable;
9use crate::compute::MinMaxKernel;
10use crate::compute::MinMaxKernelAdapter;
11use crate::compute::MinMaxResult;
12use crate::compute::{self};
13use crate::register_kernel;
14use crate::scalar::Scalar;
15
16impl MinMaxKernel for ExtensionVTable {
17 fn min_max(&self, array: &ExtensionArray) -> VortexResult<Option<MinMaxResult>> {
18 let non_nullable_ext_dtype = array.ext_dtype().with_nullability(Nullability::NonNullable);
19 Ok(
20 compute::min_max(array.storage())?.map(|MinMaxResult { min, max }| MinMaxResult {
21 min: Scalar::extension_ref(non_nullable_ext_dtype.clone(), min),
22 max: Scalar::extension_ref(non_nullable_ext_dtype, max),
23 }),
24 )
25 }
26}
27
28register_kernel!(MinMaxKernelAdapter(ExtensionVTable).lift());