File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed
algo/src/main/java/org/neo4j/gds/hdbscan Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -65,7 +65,7 @@ private BoruvkaMST(
6565
6666 this .coreValues = coreValues ;
6767 //for now use existing tool
68- this .unionFind = new HugeAtomicDisjointSetStruct (nodeCount , new Concurrency ( 1 ) );
68+ this .unionFind = new HugeAtomicDisjointSetStruct (nodeCount , concurrency );
6969
7070 this .edges = HugeObjectArray .newArray (Edge .class , nodeCount - 1 );
7171 this .nodeCount = nodeCount ;
@@ -104,7 +104,8 @@ public static BoruvkaMST create(
104104 var cores = coreResult .createCoreArray ();
105105 var closestTracker = ClosestDistanceInformationTracker .create (nodeCount , cores , coreResult );
106106
107- return new BoruvkaMST (nodePropertyValues ,
107+ return new BoruvkaMST (
108+ nodePropertyValues ,
108109 kdTree ,
109110 closestTracker ,
110111 cores ,
@@ -132,7 +133,9 @@ private void performIteration() {
132133 if (closestDistanceTracker .isNotUpdated ()) {
133134
134135 ParallelUtil .parallelForEachNode (
135- nodeCount , concurrency , terminationFlag ,
136+ nodeCount ,
137+ concurrency ,
138+ terminationFlag ,
136139 (q ) -> {
137140 var qArray = nodePropertyValues .doubleArrayValue (q );
138141 var qComp = unionFind .setIdOf (q );
You can’t perform that action at this time.
0 commit comments