Skip to content

Commit 8c3431e

Browse files
committed
[ALGOS-267] feat(algos): Fix bugs for template query;
1 parent ae0522e commit 8c3431e

File tree

1 file changed

+12
-11
lines changed

1 file changed

+12
-11
lines changed

GDBMS_ALGO/community/louvain.gsql

Lines changed: 12 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -78,23 +78,24 @@ CREATE TEMPLATE QUERY GDBMS_ALGO.community.louvain(
7878
// -------------------- 1. First pass --------------------
7979
// Initialization
8080
All_Nodes = {v_type_set};
81-
Pass_Nodes = SELECT s
82-
FROM All_Nodes:s -(e_type_set:e)- :t
83-
ACCUM @@m += e.getAttr(weight_attribute, "DOUBLE") / 2,
84-
s.@k += e.getAttr(weight_attribute, "DOUBLE"),
85-
IF s == t THEN // Self-loop link
86-
s.@k_self_loop += e.getAttr(weight_attribute, "DOUBLE")
87-
END
88-
POST-ACCUM
89-
s.@community_id = s,
90-
s.@vid = getvid(s),
91-
s.@batch_id = s.@vid % total_batch_count;
81+
All_Nodes = SELECT s
82+
FROM All_Nodes:s -(e_type_set:e)- :t
83+
ACCUM @@m += e.getAttr(weight_attribute, "DOUBLE") / 2,
84+
s.@k += e.getAttr(weight_attribute, "DOUBLE"),
85+
IF s == t THEN // Self-loop link
86+
s.@k_self_loop += e.getAttr(weight_attribute, "DOUBLE")
87+
END
88+
POST-ACCUM
89+
s.@community_id = s,
90+
s.@vid = getvid(s),
91+
s.@batch_id = s.@vid % total_batch_count;
9292
IF @@m < 0.00000000001 THEN
9393
RETURN;
9494
END;
9595

9696
// Local moving
9797
INT hop = 0;
98+
Pass_Nodes = All_Nodes;
9899
Candidates (ANY) = Pass_Nodes;
99100
WHILE Candidates.size() > 0 AND hop < maximum_iteration DO
100101
hop = hop + 1;

0 commit comments

Comments
 (0)