Merge pull request #9908 from lassewesth/diespecs17

migrate estimation cli toundirected to application layer

Author: lassewesth

algo/build.gradle

@@ -80,6 +80,7 @@ dependencies {
 
     testImplementation project(':centrality-algorithms')
     testImplementation project(':community-algorithms')
+    testImplementation project(':miscellaneous-algorithms')
     testImplementation project(':node-embedding-algorithms')
     testImplementation project(':path-finding-algorithms')
     testImplementation project(':similarity-algorithms')

algo/src/main/java/org/neo4j/gds/undirected/ToUndirectedAlgorithmFactory.java

@@ -26,11 +26,15 @@
 import org.neo4j.gds.RelationshipType;
 import org.neo4j.gds.api.Graph;
 import org.neo4j.gds.api.GraphStore;
+import org.neo4j.gds.applications.algorithms.machinery.ProgressTrackerCreator;
+import org.neo4j.gds.applications.algorithms.machinery.RequestScopedDependencies;
+import org.neo4j.gds.applications.algorithms.miscellaneous.MiscellaneousAlgorithms;
 import org.neo4j.gds.core.Aggregation;
 import org.neo4j.gds.core.concurrency.DefaultPool;
 import org.neo4j.gds.core.loading.SingleTypeRelationships;
 import org.neo4j.gds.core.utils.progress.EmptyTaskRegistryFactory;
 import org.neo4j.gds.core.utils.progress.tasks.ProgressTracker;
+import org.neo4j.gds.core.utils.warnings.EmptyUserLogRegistryFactory;
 import org.neo4j.gds.extension.GdlExtension;
 import org.neo4j.gds.extension.GdlGraph;
 import org.neo4j.gds.extension.Inject;
@@ -312,22 +316,24 @@ void shouldAggregateWithPropertiesAndLocalAggregation() {
     @Test
     void shouldLogProgress() {
         var log = new GdsTestLog();
+        var requestScopedDependencies = RequestScopedDependencies.builder()
+            .taskRegistryFactory(EmptyTaskRegistryFactory.INSTANCE)
+            .terminationFlag(TerminationFlag.RUNNING_TRUE)
+            .userLogRegistryFactory(EmptyUserLogRegistryFactory.INSTANCE)
+            .build();
+        var progressTrackerCreator = new ProgressTrackerCreator(log, requestScopedDependencies);
+        var miscellaneousAlgorithms = new MiscellaneousAlgorithms(
+            progressTrackerCreator,
+            requestScopedDependencies.terminationFlag()
+        );
 
         var config = ToUndirectedConfigImpl
             .builder()
             .concurrency(4)
             .relationshipType("T1")
             .mutateRelationshipType("T2")
             .build();
-
-        ToUndirected toUndirected = new ToUndirectedAlgorithmFactory().build(
-            directedGraphStore,
-            config,
-            log,
-            EmptyTaskRegistryFactory.INSTANCE
-        );
-
-        toUndirected.compute();
+        miscellaneousAlgorithms.toUndirected(directedGraphStore, config);
 
         var messagesInOrder = log.getMessages(INFO);
 

algo/src/test/java/org/neo4j/gds/undirected/ToUndirectedTest.java

@@ -50,13 +50,13 @@
 import java.util.Set;
 import java.util.stream.Collectors;
 
-class MiscellaneousAlgorithms {
+public class MiscellaneousAlgorithms {
     private final AlgorithmMachinery algorithmMachinery = new AlgorithmMachinery();
 
     private final ProgressTrackerCreator progressTrackerCreator;
     private final TerminationFlag terminationFlag;
 
-    MiscellaneousAlgorithms(ProgressTrackerCreator progressTrackerCreator, TerminationFlag terminationFlag) {
+    public MiscellaneousAlgorithms(ProgressTrackerCreator progressTrackerCreator, TerminationFlag terminationFlag) {
         this.progressTrackerCreator = progressTrackerCreator;
         this.terminationFlag = terminationFlag;
     }
@@ -150,7 +150,7 @@ ScalePropertiesResult scaleProperties(Graph graph, ScalePropertiesBaseConfig con
         );
     }
 
-    SingleTypeRelationships toUndirected(GraphStore graphStore, ToUndirectedConfig configuration) {
+    public SingleTypeRelationships toUndirected(GraphStore graphStore, ToUndirectedConfig configuration) {
         var task = Tasks.task(
             AlgorithmLabel.ToUndirected.asString(),
             Tasks.leaf("Create Undirected Relationships", graphStore.nodeCount()),

algorithm-specifications/src/main/java/org/neo4j/gds/undirected/Constants.java

@@ -77,6 +77,21 @@ public MemoryEstimateResult scaleProperties(
     }
 
     public MemoryEstimation toUndirected(ToUndirectedConfig configuration) {
-        return new ToUndirectedMemoryEstimateDefinition(ToUndirectedConfigTransformer.toMemoryEstimateParameters(configuration)).memoryEstimation();
+        var parameters = ToUndirectedConfigTransformer.toMemoryEstimateParameters(configuration);
+
+        return new ToUndirectedMemoryEstimateDefinition(parameters).memoryEstimation();
+    }
+
+    public MemoryEstimateResult toUndirected(
+        ToUndirectedConfig configuration,
+        Object graphNameOrConfiguration
+    ) {
+        var memoryEstimation = toUndirected(configuration);
+
+        return algorithmEstimationTemplate.estimate(
+            configuration,
+            graphNameOrConfiguration,
+            memoryEstimation
+        );
     }
 }

algorithm-specifications/src/main/java/org/neo4j/gds/undirected/ToUndirectedSpec.java

@@ -21,7 +21,6 @@
 
 import org.neo4j.gds.applications.algorithms.machinery.AlgorithmProcessingTimings;
 import org.neo4j.gds.procedures.algorithms.results.StandardMutateResult;
-import org.neo4j.gds.result.AbstractResultBuilder;
 
 import java.util.Map;
 
@@ -57,26 +56,4 @@ public static ToUndirectedMutateResult emptyFrom(
             configurationMap
         );
     }
-
-    public static class Builder extends AbstractResultBuilder<ToUndirectedMutateResult> {
-        private long inputRelationships;
-
-        public Builder withInputRelationships(long inputRelationships) {
-            this.inputRelationships = inputRelationships;
-            return this;
-        }
-
-        @Override
-        public ToUndirectedMutateResult build() {
-            return new ToUndirectedMutateResult(
-                preProcessingMillis,
-                computeMillis,
-                mutateMillis,
-                0,
-                inputRelationships,
-                relationshipsWritten,
-                config.toMap()
-            );
-        }
-    }
 }