Merge pull request #11172 from IoannisPanagiotas/community-compute-facade

Community compute facade

Author: IoannisPanagiotas

algo/src/main/java/org/neo4j/gds/CommunityAlgorithmTasks.java

@@ -28,7 +28,7 @@
 import org.neo4j.gds.core.utils.progress.tasks.Task;
 import org.neo4j.gds.core.utils.progress.tasks.Tasks;
 import org.neo4j.gds.hdbscan.HDBScanProgressTrackerCreator;
-import org.neo4j.gds.k1coloring.K1ColoringBaseConfig;
+import org.neo4j.gds.k1coloring.K1ColoringParameters;
 import org.neo4j.gds.k1coloring.K1ColoringProgressTrackerTaskCreator;
 import org.neo4j.gds.kmeans.KMeansTaskFactory;
 import org.neo4j.gds.kmeans.KmeansParameters;
@@ -70,10 +70,10 @@ public Task hdbscan(Graph graph) {
         return HDBScanProgressTrackerCreator.hdbscanTask(AlgorithmLabel.HDBScan.asString(), graph.nodeCount());
     }
 
-    public Task k1Coloring(Graph graph, K1ColoringBaseConfig configuration) {
+    public Task k1Coloring(Graph graph, K1ColoringParameters parameters) {
         return K1ColoringProgressTrackerTaskCreator.progressTask(
             graph.nodeCount(),
-            configuration.maxIterations()
+            parameters.maxIterations()
         );
     }
 

algo/src/main/java/org/neo4j/gds/approxmaxkcut/ApproxMaxKCutResult.java

@@ -24,4 +24,7 @@
 public record ApproxMaxKCutResult(
         HugeByteArray candidateSolution,
         double cutCost
-    ) {}
+    ) {
+
+    public static ApproxMaxKCutResult EMPTY  = new ApproxMaxKCutResult(HugeByteArray.newArray(0),0d);
+}

algo/src/main/java/org/neo4j/gds/cliqueCounting/CliqueCountingResult.java

@@ -25,4 +25,7 @@ public record CliqueCountingResult(
     long[] globalCount,
     HugeObjectArray<long[]> perNodeCount,
     long[][] perSubcliqueCount
-){}
+){
+
+    public static CliqueCountingResult EMPTY = new CliqueCountingResult(new long[0], HugeObjectArray.newArray(long[].class,0), new long[0][0]);
+}

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);
+}

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

@@ -21,4 +21,7 @@
 
 import org.neo4j.gds.collections.ha.HugeLongArray;
 
-public record Labels(HugeLongArray labels, long numberOfNoisePoints, long numberOfClusters) {}
+public record Labels(HugeLongArray labels, long numberOfNoisePoints, long numberOfClusters) {
+
+    public static Labels EMPTY = new Labels(HugeLongArray.newArray(0),0, 0);
+}

algo/src/main/java/org/neo4j/gds/k1coloring/K1ColoringResult.java

@@ -39,4 +39,6 @@ public BitSet usedColors() {
         return usedColors;
     }
 
+    public static  K1ColoringResult EMPTY = new K1ColoringResult(HugeLongArray.newArray(0),0, false);
+
 }

algo/src/main/java/org/neo4j/gds/kcore/KCoreDecompositionResult.java

@@ -21,4 +21,7 @@
 
 import org.neo4j.gds.collections.ha.HugeIntArray;
 
-public record KCoreDecompositionResult(HugeIntArray coreValues, int degeneracy){}
+public record KCoreDecompositionResult(HugeIntArray coreValues, int degeneracy){
+
+public static KCoreDecompositionResult EMPTY = new KCoreDecompositionResult(HugeIntArray.newArray(0), 0);
+}

algo/src/main/java/org/neo4j/gds/kmeans/KmeansResult.java

@@ -30,4 +30,16 @@ public record KmeansResult(
     double averageDistanceToCentroid,
     @Nullable HugeDoubleArray silhouette,
     double averageSilhouette
-) {}
+) {
+    public static KmeansResult empty(int k) {
+        return new KmeansResult(
+            HugeIntArray.newArray(0),
+            HugeDoubleArray.newArray(0),
+            new double[k][0],
+            0,
+            null,
+            0
+        );
+    }
+
+}

algo/src/main/java/org/neo4j/gds/labelpropagation/LabelPropagationResult.java

@@ -21,4 +21,7 @@
 
 import org.neo4j.gds.collections.ha.HugeLongArray;
 
-public record LabelPropagationResult(HugeLongArray labels, boolean didConverge, long ranIterations) {}
+public record LabelPropagationResult(HugeLongArray labels, boolean didConverge, long ranIterations) {
+
+    public static LabelPropagationResult EMPTY = new LabelPropagationResult(HugeLongArray.newArray(0), false, 0);
+}

algo/src/main/java/org/neo4j/gds/leiden/LeidenResult.java

@@ -22,8 +22,6 @@
 import org.jetbrains.annotations.Nullable;
 import org.neo4j.gds.collections.ha.HugeLongArray;
 
-import java.util.function.LongUnaryOperator;
-
 public record LeidenResult(
     HugeLongArray communities,
     int ranLevels,
@@ -50,8 +48,13 @@ public long[] intermediateCommunities(long nodeId) {
 
     }
 
-    public  LongUnaryOperator communitiesFunction() {
-        return communities::get;
-    }
+    public static LeidenResult EMPTY = new LeidenResult(
+        HugeLongArray.newArray(0),
+        0,
+        false,
+        null,
+        new double[0],
+        0
+    );
 
 }