Function arrow_max

nodedb/src/control/arrow_convert.rs:202–213

Compute MAX of a numeric column using Arrow SIMD kernels.

(batch: &RecordBatch, column_name: &str)

/// Compute MAX of a numeric column using Arrow SIMD kernels.
pub fn arrow_max(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::max(f64_arr)
    } else if let Some(i64_arr) = array.as_any().downcast_ref::<Int64Array>() {
        arrow::compute::kernels::aggregate::max(i64_arr).map(|v| v as f64)
    } else {
        None
    }
}

/// Compute COUNT of non-null values in a column.
pub fn arrow_count(batch: &RecordBatch, column_name: &str) -> Option<usize> {