Function arrow_min

nodedb/src/control/arrow_convert.rs:188–199

Compute MIN of a numeric column using Arrow SIMD kernels.

(batch: &RecordBatch, column_name: &str)

/// Compute MIN of a numeric column using Arrow SIMD kernels.
pub fn arrow_min(batch: &RecordBatch, column_name: &str) -> Option<f64> {
    let idx = batch.schema().index_of(column_name).ok()?;
    let array = batch.column(idx);

    if let Some(f64_arr) = array.as_any().downcast_ref::<Float64Array>() {
        arrow::compute::kernels::aggregate::min(f64_arr)
    } else if let Some(i64_arr) = array.as_any().downcast_ref::<Int64Array>() {
        arrow::compute::kernels::aggregate::min(i64_arr).map(|v| v as f64)
    } else {
        None
    }
}

/// Compute MAX of a numeric column using Arrow SIMD kernels.
pub fn arrow_max(batch: &RecordBatch, column_name: &str) -> Option<f64> {