uni-algo 2.2.0

Graph algorithms for Uni - PageRank, Louvain, shortest paths, and more
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

// SPDX-License-Identifier: Apache-2.0
// Copyright 2024-2026 Dragonscale Team

//! uni.algo.labelPropagation procedure implementation.

use crate::algo::algorithms::{Algorithm, LabelPropagation, LabelPropagationConfig};
use crate::algo::procedure_template::{
    GenericAlgoProcedure, GraphAlgoAdapter, arg_bool, arg_str, arg_u64,
};
use crate::algo::procedures::{AlgoResultRow, ValueType};
use anyhow::Result;
use serde_json::{Value, json};

pub struct LabelPropagationAdapter;

impl GraphAlgoAdapter for LabelPropagationAdapter {
    const NAME: &'static str = "uni.algo.labelPropagation";
    type Algo = LabelPropagation;

    fn specific_args() -> Vec<(&'static str, ValueType, Option<Value>)> {
        vec![
            ("maxIterations", ValueType::Int, Some(json!(10))),
            ("write", ValueType::Bool, Some(json!(false))),
            ("writeProperty", ValueType::String, Some(json!("community"))),
            // Optional RNG seed; null => deterministic default seed.
            ("seed", ValueType::Int, Some(Value::Null)),
        ]
    }

    fn yields() -> Vec<(&'static str, ValueType)> {
        vec![("nodeId", ValueType::Int), ("communityId", ValueType::Int)]
    }

    fn to_config(args: Vec<Value>) -> Result<LabelPropagationConfig> {
        Ok(LabelPropagationConfig {
            max_iterations: arg_u64(&args, 0, "maxIterations")? as usize,
            write: arg_bool(&args, 1, "write")?,
            write_property: arg_str(&args, 2, "writeProperty")?.to_string(),
            seed_property: None,
            seed: args.get(3).and_then(Value::as_u64),
        })
    }

    fn map_result(result: <Self::Algo as Algorithm>::Result) -> Result<Vec<AlgoResultRow>> {
        Ok(result
            .communities
            .into_iter()
            .map(|(vid, cid)| AlgoResultRow {
                values: vec![json!(vid.as_u64()), json!(cid)],
            })
            .collect())
    }
}

pub type LabelPropagationProcedure = GenericAlgoProcedure<LabelPropagationAdapter>;