From a0e39ace467f432131cb0f34fd29189161189ca8 Mon Sep 17 00:00:00 2001 From: ioannispan Date: Fri, 9 Aug 2024 10:34:40 +0200 Subject: [PATCH] Minor smaller size --- .../neo4j/gds/steiner/SteinerBasedDeltaStepping.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/algo/src/main/java/org/neo4j/gds/steiner/SteinerBasedDeltaStepping.java b/algo/src/main/java/org/neo4j/gds/steiner/SteinerBasedDeltaStepping.java index 51aa3086a5..5b8df6ba4a 100644 --- a/algo/src/main/java/org/neo4j/gds/steiner/SteinerBasedDeltaStepping.java +++ b/algo/src/main/java/org/neo4j/gds/steiner/SteinerBasedDeltaStepping.java @@ -24,17 +24,17 @@ import com.carrotsearch.hppc.LongArrayDeque; import org.neo4j.gds.Algorithm; import org.neo4j.gds.api.Graph; +import org.neo4j.gds.collections.ha.HugeLongArray; import org.neo4j.gds.collections.haa.HugeAtomicDoubleArray; import org.neo4j.gds.collections.haa.HugeAtomicLongArray; import org.neo4j.gds.core.concurrency.Concurrency; import org.neo4j.gds.core.concurrency.ParallelUtil; -import org.neo4j.gds.mem.MemoryEstimation; -import org.neo4j.gds.mem.MemoryEstimations; -import org.neo4j.gds.mem.MemoryRange; -import org.neo4j.gds.collections.ha.HugeLongArray; import org.neo4j.gds.core.utils.progress.tasks.ProgressTracker; import org.neo4j.gds.core.utils.queue.HugeLongPriorityQueue; import org.neo4j.gds.mem.Estimate; +import org.neo4j.gds.mem.MemoryEstimation; +import org.neo4j.gds.mem.MemoryEstimations; +import org.neo4j.gds.mem.MemoryRange; import org.neo4j.gds.paths.ImmutablePathResult; import org.neo4j.gds.paths.PathResult; import org.neo4j.gds.paths.delta.TentativeDistances; @@ -304,7 +304,7 @@ public PathFindingResult compute() { mergedWithSource.set(startNode); this.distances.set(startNode, -1, 0); - HugeLongPriorityQueue terminalQueue = HugeLongPriorityQueue.min(unvisitedTerminal.size()); + HugeLongPriorityQueue terminalQueue = HugeLongPriorityQueue.min(graph.nodeCount()); var terminalQueueLock = new ReentrantLock(); var tasks = IntStream .range(0, concurrency.value())