Method write

nodedb/src/engine/graph/algo/result.rs:199–226

(&self, writer: &mut W)

impl zerompk::ToMessagePack for AlgoResultBatch {
    fn write<W: zerompk::Write>(&self, writer: &mut W) -> zerompk::Result<()> {
        let schema = self.algorithm.result_schema();
        let num_cols = schema.len();

        writer.write_array_len(self.row_count)?;

        for row_idx in 0..self.row_count {
            writer.write_map_len(num_cols)?;

            for (col_idx, &(col_name, _)) in schema.iter().enumerate() {
                let (col_type, vec_idx) = self.column_map[col_idx];
                writer.write_string(col_name)?;
                match col_type {
                    AlgoColumnType::Text => {
                        writer.write_string(&self.text_columns[vec_idx][row_idx])?;
                    }
                    AlgoColumnType::Float64 => {
                        writer.write_f64(self.f64_columns[vec_idx][row_idx])?;
                    }
                    AlgoColumnType::Int64 => {
                        writer.write_i64(self.i64_columns[vec_idx][row_idx])?;
                    }
                }
            }
        }

        Ok(())
    }
}

#[cfg(test)]