Skip to content

Commit ec2c379

Browse files
minor
1 parent b577920 commit ec2c379

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

algo/src/main/java/org/neo4j/gds/hdbscan/BoruvkaMST.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff 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);

0 commit comments

Comments
 (0)