Remote SLLPA mutate

Author: IoannisPanagiotas

proc/community/src/main/java/org/neo4j/gds/sllpa/SpeakerListenerLPAMutateProc.java

@@ -47,7 +47,7 @@ public Stream<SpeakerListenerLPAMutateResult> mutate(
         @Name(value = "graphName") String graphName,
         @Name(value = "configuration", defaultValue = "{}") Map<String, Object> configuration
     ) {
-        return facade.algorithms().community().speakerListenerLPAMutateStub().execute(graphName,configuration);
+        return facade.algorithms().community().sllpaMutate(graphName,configuration);
     }
 
     @Procedure(value = "gds.sllpa.mutate.estimate", mode = READ)
@@ -56,7 +56,7 @@ public Stream<MemoryEstimateResult> estimate(
         @Name(value = "graphNameOrConfiguration") Object graphNameOrConfiguration,
         @Name(value = "algoConfiguration") Map<String, Object> algoConfiguration
     ) {
-        return facade.algorithms().community().speakerListenerLPAMutateStub().estimate(graphNameOrConfiguration, algoConfiguration);
+        return facade.algorithms().community().sllpaMutateEstimate(graphNameOrConfiguration, algoConfiguration);
     }
 
     @Internal

procedures/algorithms-facade/src/main/java/org/neo4j/gds/procedures/algorithms/community/LocalCommunityProcedureFacade.java

@@ -1467,6 +1467,24 @@ public Stream<SpeakerListenerLPAStatsResult> sllpaStats(String graphName, Map<St
         );
     }
 
+    @Override
+    public Stream<MemoryEstimateResult> sllpaMutateEstimate(
+        Object graphNameOrConfiguration,
+        Map<String, Object> algorithmConfiguration
+    ) {
+        return speakerListenerLPAMutateStub.estimate(
+            graphNameOrConfiguration,
+            algorithmConfiguration
+        );
+    }
+
+    @Override
+    public Stream<SpeakerListenerLPAMutateResult> sllpaMutate(String graphName, Map<String, Object> configuration) {
+        return speakerListenerLPAMutateStub.execute(
+            graphName,
+            configuration);
+    }
+
     @Override
     public Stream<MemoryEstimateResult> sllpaWriteEstimate(
         Object graphNameOrConfiguration,

procedures/facade-api/community-facade-api/src/main/java/org/neo4j/gds/procedures/algorithms/community/CommunityProcedureFacade.java

@@ -547,6 +547,16 @@ Stream<SpeakerListenerLPAStatsResult> sllpaStats(
         Map<String, Object> configuration
     );
 
+    Stream<MemoryEstimateResult> sllpaMutateEstimate(
+        Object graphNameOrConfiguration,
+        Map<String, Object> algorithmConfiguration
+    );
+
+    Stream<SpeakerListenerLPAMutateResult> sllpaMutate(
+        String graphName,
+        Map<String, Object> configuration
+    );
+
     Stream<MemoryEstimateResult> sllpaWriteEstimate(
         Object graphNameOrConfiguration,
         Map<String, Object> algorithmConfiguration

procedures/facade-api/community-facade-api/src/main/java/org/neo4j/gds/procedures/algorithms/community/SpeakerListenerLPAMutateResult.java

@@ -23,13 +23,29 @@
 
 import java.util.Map;
 
-public record SpeakerListenerLPAMutateResult(long ranIterations, boolean didConverge, long preProcessingMillis, long computeMillis, long mutateMillis, long nodePropertiesWritten, Map<String,Object> configuration){
+public record SpeakerListenerLPAMutateResult(
+    long ranIterations,
+    boolean didConverge,
+    long preProcessingMillis,
+    long computeMillis,
+    long mutateMillis,
+    long nodePropertiesWritten,
+    Map<String,Object> configuration
+){
 
     public static SpeakerListenerLPAMutateResult emptyFrom(
         AlgorithmProcessingTimings timings,
         Map<String, Object> configurationMap
     ) {
-        return new SpeakerListenerLPAMutateResult(0,false,timings.preProcessingMillis,timings.computeMillis,timings.sideEffectMillis, 0,configurationMap);
+        return new SpeakerListenerLPAMutateResult(
+            0,
+            false,
+            timings.preProcessingMillis,
+            timings.computeMillis,
+            timings.sideEffectMillis,
+            0,
+            configurationMap
+        );
     }
 }
 

procedures/facade-api/configs/community-configs/src/main/java/org/neo4j/gds/sllpa/SpeakerListenerLPAConfig.java

@@ -23,7 +23,7 @@
 import org.neo4j.gds.beta.pregel.PregelProcedureConfig;
 import org.neo4j.gds.core.CypherMapWrapper;
 
-@Configuration
+@Configuration("SpeakerListenerLPAConfigImpl")
 public interface SpeakerListenerLPAConfig extends PregelProcedureConfig {
 
         default double minAssociationStrength() {