(batch: &AlgoResultBatch)
| 130 | } |
| 131 | |
| 132 | fn parse_results(batch: &AlgoResultBatch) -> std::collections::HashMap<String, f64> { |
| 133 | let json = batch.to_json().unwrap(); |
| 134 | let rows: Vec<serde_json::Value> = serde_json::from_slice(&json).unwrap(); |
| 135 | rows.iter() |
| 136 | .map(|r| { |
| 137 | ( |
| 138 | r["node_id"].as_str().unwrap().to_string(), |
| 139 | // f64::INFINITY serializes as null in JSON. |
| 140 | r["distance"].as_f64().unwrap_or(f64::INFINITY), |
| 141 | ) |
| 142 | }) |
| 143 | .collect() |
| 144 | } |
| 145 | |
| 146 | #[test] |
| 147 | fn sssp_shortest_via_relay() { |