migrate estimation cli wcc to application layer

but not the factory because that is widely used

Author: lassewesth

algo/src/main/java/org/neo4j/gds/wcc/Wcc.java

@@ -59,27 +59,6 @@ public class Wcc extends Algorithm<DisjointSetStruct> {
 
     private final Graph graph;
 
-    /**
-     * @deprecated Stop using this, use the variant that does direct injection of termination flag instead
-     */
-    @Deprecated
-    public Wcc(
-        Graph graph,
-        ExecutorService executor,
-        int minBatchSize,
-        WccParameters parameters,
-        ProgressTracker progressTracker
-    ) {
-        this(
-            graph,
-            executor,
-            minBatchSize,
-            parameters,
-            progressTracker,
-            TerminationFlag.RUNNING_TRUE
-        );
-    }
-
     public Wcc(
         Graph graph,
         ExecutorService executor,

algo/src/main/java/org/neo4j/gds/wcc/WccAlgorithmFactory.java

@@ -29,6 +29,7 @@
 import org.neo4j.gds.core.utils.progress.tasks.ProgressTracker;
 import org.neo4j.gds.core.utils.progress.tasks.Task;
 import org.neo4j.gds.core.utils.progress.tasks.Tasks;
+import org.neo4j.gds.termination.TerminationFlag;
 
 public final class WccAlgorithmFactory<CONFIG extends WccBaseConfig> extends GraphAlgorithmFactory<Wcc, CONFIG> {
 
@@ -51,7 +52,8 @@ public Wcc build(
             DefaultPool.INSTANCE,
             ParallelUtil.DEFAULT_BATCH_SIZE,
             parameters,
-            progressTracker
+            progressTracker,
+            TerminationFlag.RUNNING_TRUE
         );
     }
 

algo/src/test/java/org/neo4j/gds/wcc/IncrementalWccTest.java

@@ -27,6 +27,7 @@
 import org.neo4j.gds.core.concurrency.DefaultPool;
 import org.neo4j.gds.core.utils.paged.dss.DisjointSetStruct;
 import org.neo4j.gds.core.utils.progress.tasks.ProgressTracker;
+import org.neo4j.gds.termination.TerminationFlag;
 
 import java.util.Optional;
 import java.util.stream.Collectors;
@@ -123,7 +124,8 @@ private DisjointSetStruct run(Graph graph, WccParameters parameters) {
             DefaultPool.INSTANCE,
             COMMUNITY_SIZE / ConcurrencyConfig.DEFAULT_CONCURRENCY,
             parameters,
-            ProgressTracker.NULL_TRACKER
+            ProgressTracker.NULL_TRACKER,
+            TerminationFlag.RUNNING_TRUE
         ).compute();
     }
 

algo/src/test/java/org/neo4j/gds/wcc/WccTest.java

@@ -42,6 +42,7 @@
 import org.neo4j.gds.extension.Inject;
 import org.neo4j.gds.extension.TestGraph;
 import org.neo4j.gds.logging.GdsTestLog;
+import org.neo4j.gds.termination.TerminationFlag;
 
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -218,7 +219,8 @@ DisjointSetStruct run(Graph graph, WccParameters parameters, int concurrency) {
             DefaultPool.INSTANCE,
             communitySize() / concurrency,
             parameters,
-            ProgressTracker.NULL_TRACKER
+            ProgressTracker.NULL_TRACKER,
+            TerminationFlag.RUNNING_TRUE
         ).compute();
     }
 

algo/src/test/java/org/neo4j/gds/wcc/WccThresholdTest.java

@@ -31,6 +31,7 @@
 import org.neo4j.gds.extension.GdlGraph;
 import org.neo4j.gds.extension.Inject;
 import org.neo4j.gds.extension.TestGraph;
+import org.neo4j.gds.termination.TerminationFlag;
 
 import java.util.stream.Stream;
 
@@ -110,7 +111,8 @@ private void assertResults(double threshold, TestGraph graph, String[][] expecte
             DefaultPool.INSTANCE,
             DEFAULT_BATCH_SIZE,
             parameters,
-            ProgressTracker.NULL_TRACKER
+            ProgressTracker.NULL_TRACKER,
+            TerminationFlag.RUNNING_TRUE
         ).compute();
 
         long[] communityData = new long[(int) graph.nodeCount()];