Add conductance in compute facade

Author: IoannisPanagiotas

algo/src/main/java/org/neo4j/gds/conductance/ConductanceResult.java

@@ -24,4 +24,7 @@
 public record ConductanceResult(
         HugeSparseDoubleArray communityConductances,
         double globalAverageConductance
-    ) {}
+    ) {
+
+    public static ConductanceResult EMPTY = new ConductanceResult(HugeSparseDoubleArray.builder(0).build(),0d);
+}

algorithms-compute-facade/src/main/java/org/neo4j/gds/community/CommunityComputeFacade.java

@@ -29,6 +29,9 @@
 import org.neo4j.gds.cliqueCounting.CliqueCounting;
 import org.neo4j.gds.cliqueCounting.CliqueCountingResult;
 import org.neo4j.gds.cliquecounting.CliqueCountingParameters;
+import org.neo4j.gds.conductance.Conductance;
+import org.neo4j.gds.conductance.ConductanceParameters;
+import org.neo4j.gds.conductance.ConductanceResult;
 import org.neo4j.gds.core.concurrency.DefaultPool;
 import org.neo4j.gds.core.utils.progress.JobId;
 import org.neo4j.gds.result.TimedAlgorithmResult;
@@ -123,7 +126,40 @@ CompletableFuture<TimedAlgorithmResult<CliqueCountingResult>> cliqueCounting(
             algorithm::compute,
             jobId
         );
+    }
+
+    CompletableFuture<TimedAlgorithmResult<ConductanceResult>> conductance(
+        Graph graph,
+        ConductanceParameters parameters,
+        JobId jobId,
+        boolean logProgress
+    ) {
+
+        if (graph.isEmpty()) {
+            return CompletableFuture.completedFuture(TimedAlgorithmResult.empty(ConductanceResult.EMPTY));
+        }
+
+        var progressTracker = progressTrackerFactory.create(
+            tasks.conductance(graph),
+            jobId,
+            parameters.concurrency(),
+            logProgress
+        );
+
+        var algorithm = new Conductance(
+            graph,
+            parameters.concurrency(),
+            parameters.minBatchSize(),
+            parameters.hasRelationshipWeightProperty(),
+            parameters.communityProperty(),
+            DefaultPool.INSTANCE,
+            progressTracker
+        );
 
+        return algorithmCaller.run(
+            algorithm::compute,
+            jobId
+        );
     }
 
 }

algorithms-compute-facade/src/test/java/org/neo4j/gds/community/CommunityComputeFacadeEmptyGraphTest.java

@@ -30,14 +30,12 @@
 import org.neo4j.gds.approxmaxkcut.ApproxMaxKCutResult;
 import org.neo4j.gds.async.AsyncAlgorithmCaller;
 import org.neo4j.gds.cliqueCounting.CliqueCountingResult;
-import org.neo4j.gds.cliquecounting.CliqueCountingMode;
 import org.neo4j.gds.cliquecounting.CliqueCountingParameters;
-import org.neo4j.gds.core.concurrency.Concurrency;
+import org.neo4j.gds.conductance.ConductanceParameters;
+import org.neo4j.gds.conductance.ConductanceResult;
 import org.neo4j.gds.core.utils.progress.JobId;
 import org.neo4j.gds.termination.TerminationFlag;
 
-import java.util.List;
-
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verifyNoInteractions;
@@ -88,11 +86,7 @@ void maxKCut() {
     void cliqueCounting(){
         var future = facade.cliqueCounting(
             graph,
-            new CliqueCountingParameters(
-                CliqueCountingMode.GloballyOnly,
-                List.of(),
-                new Concurrency(4)
-            ),
+            mock(CliqueCountingParameters.class),
             jobIdMock,
             false
         );
@@ -104,5 +98,20 @@ void cliqueCounting(){
         verifyNoInteractions(algorithmCallerMock);
     }
 
+    @Test
+    void conductance(){
+        var future = facade.conductance(
+            graph,
+            mock(ConductanceParameters.class),
+            jobIdMock,
+            false
+        );
+
+        var results = future.join();
+
+        assertThat(results.result()).isEqualTo(ConductanceResult.EMPTY);
+        verifyNoInteractions(progressTrackerFactoryMock);
+        verifyNoInteractions(algorithmCallerMock);
+    }
 
 }

algorithms-compute-facade/src/test/java/org/neo4j/gds/community/CommunityComputeFacadeTest.java

@@ -30,6 +30,7 @@
 import org.neo4j.gds.async.AsyncAlgorithmCaller;
 import org.neo4j.gds.cliquecounting.CliqueCountingMode;
 import org.neo4j.gds.cliquecounting.CliqueCountingParameters;
+import org.neo4j.gds.conductance.ConductanceParameters;
 import org.neo4j.gds.core.concurrency.Concurrency;
 import org.neo4j.gds.core.utils.progress.JobId;
 import org.neo4j.gds.core.utils.progress.tasks.ProgressTracker;
@@ -67,8 +68,8 @@ class CommunityComputeFacadeTest {
 
     @GdlGraph(orientation = Orientation.UNDIRECTED)
     private static final String GDL = """
-        (a:Node { prize: 1.0 })-[:REL]->(b:Node { prize: 2.0 }),
-        (b)-[:REL]->(c:Node { prize: 3.0 }),
+        (a:Node { prop: 1, prop2: [1.0] })-[:REL]->(b:Node { prop: 1,prop2: [2.0] }),
+        (b)-[:REL]->(c:Node { prop: 3 ,prop2: [3.0]}),
         (a)-[:REL]->(c)
         """;
 
@@ -137,4 +138,24 @@ void cliqueCounting(){
         assertThat(results.result().globalCount()).containsExactly(1);
         assertThat(results.computeMillis()).isNotNegative();
     }
+
+    @Test
+    void conductance(){
+        var future = facade.conductance(
+            graph,
+            new ConductanceParameters(
+               new Concurrency(4),
+                10_000,
+                false,
+                "prop"
+            ),
+            jobIdMock,
+            false
+        );
+
+        var results = future.join();
+
+        assertThat(results.result().globalAverageConductance()).isGreaterThan(0d);
+        assertThat(results.computeMillis()).isNotNegative();
+    }
 }