Method new

nodedb/src/engine/graph/algo/result.rs:36–68

Create a new result batch for the given algorithm.

(algorithm: GraphAlgorithm)

impl AlgoResultBatch {
    /// Create a new result batch for the given algorithm.
    pub fn new(algorithm: GraphAlgorithm) -> Self {
        let schema = algorithm.result_schema();
        let mut text_count = 0usize;
        let mut f64_count = 0usize;
        let mut i64_count = 0usize;
        let mut column_map = Vec::with_capacity(schema.len());

        for &(_, col_type) in schema {
            match col_type {
                AlgoColumnType::Text => {
                    column_map.push((col_type, text_count));
                    text_count += 1;
                }
                AlgoColumnType::Float64 => {
                    column_map.push((col_type, f64_count));
                    f64_count += 1;
                }
                AlgoColumnType::Int64 => {
                    column_map.push((col_type, i64_count));
                    i64_count += 1;
                }
            }
        }

        Self {
            algorithm,
            text_columns: vec![Vec::new(); text_count],
            f64_columns: vec![Vec::new(); f64_count],
            i64_columns: vec![Vec::new(); i64_count],
            column_map,
            row_count: 0,
        }
    }

    /// Add a row with node_id and f64 score (PageRank, SSSP, LCC, centrality).
    pub fn push_node_f64(&mut self, node_id: String, value: f64) {