Bootstrap PushbackPathFindingWriteProcedureFacade

Author: vnickolov

procedures/pushback-procedures-facade/src/main/java/org/neo4j/gds/procedures/algorithms/pathfinding/PushbackPathFindingProcedureFacade.java

@@ -25,8 +25,10 @@
 import org.neo4j.gds.procedures.algorithms.pathfinding.stats.PushbackPathFindingStatsProcedureFacade;
 import org.neo4j.gds.procedures.algorithms.pathfinding.stream.PushbackPathFindingStreamProcedureFacade;
 import org.neo4j.gds.procedures.algorithms.pathfinding.stubs.PathFindingStubs;
+import org.neo4j.gds.procedures.algorithms.pathfinding.write.PushbackPathFindingWriteProcedureFacade;
 import org.neo4j.gds.procedures.algorithms.results.StandardModeResult;
 import org.neo4j.gds.procedures.algorithms.results.StandardStatsResult;
+import org.neo4j.gds.procedures.algorithms.results.StandardWriteRelationshipsResult;
 
 import java.util.Map;
 import java.util.stream.Stream;
@@ -36,15 +38,18 @@ public final class PushbackPathFindingProcedureFacade implements PathFindingProc
     private final PushbackPathFindingMutateProcedureFacade mutateProcedureFacade;
     private final PushbackPathFindingStatsProcedureFacade statsProcedureFacade;
     private final PushbackPathFindingStreamProcedureFacade streamProcedureFacade;
+    private final PushbackPathFindingWriteProcedureFacade writeProcedureFacade;
 
     public PushbackPathFindingProcedureFacade(
         PushbackPathFindingMutateProcedureFacade mutateProcedureFacade,
         PushbackPathFindingStatsProcedureFacade statsProcedureFacade,
-        PushbackPathFindingStreamProcedureFacade streamProcedureFacade
+        PushbackPathFindingStreamProcedureFacade streamProcedureFacade,
+        PushbackPathFindingWriteProcedureFacade writeProcedureFacade
     ) {
         this.mutateProcedureFacade = mutateProcedureFacade;
         this.statsProcedureFacade = statsProcedureFacade;
         this.streamProcedureFacade = streamProcedureFacade;
+        this.writeProcedureFacade = writeProcedureFacade;
     }
 
     @Override
@@ -109,7 +114,7 @@ public Stream<MemoryEstimateResult> bellmanFordStatsEstimate(
 
     @Override
     public Stream<BellmanFordWriteResult> bellmanFordWrite(String graphName, Map<String, Object> configuration) {
-        return Stream.empty();
+        return writeProcedureFacade.bellmanFord(graphName, configuration);
     }
 
     @Override
@@ -208,11 +213,11 @@ public Stream<MemoryEstimateResult> deltaSteppingStreamEstimate(
     }
 
     @Override
-    public Stream<org.neo4j.gds.procedures.algorithms.results.StandardWriteRelationshipsResult> deltaSteppingWrite(
+    public Stream<StandardWriteRelationshipsResult> deltaSteppingWrite(
         String graphName,
         Map<String, Object> configuration
     ) {
-        return Stream.empty();
+        return writeProcedureFacade.deltaStepping(graphName, configuration);
     }
 
     @Override
@@ -251,7 +256,7 @@ public Stream<MemoryEstimateResult> depthFirstSearchStreamEstimate(
 
     @Override
     public Stream<KSpanningTreeWriteResult> kSpanningTreeWrite(String graphName, Map<String, Object> configuration) {
-        return Stream.empty();
+        return writeProcedureFacade.kSpanningTree(graphName, configuration);
     }
 
     @Override
@@ -312,7 +317,7 @@ public Stream<PrizeCollectingSteinerTreeWriteResult> prizeCollectingSteinerTreeW
         String graphName,
         Map<String, Object> configuration
     ) {
-        return Stream.empty();
+        return writeProcedureFacade.pcst(graphName, configuration);
     }
 
     @Override
@@ -398,11 +403,11 @@ public Stream<MemoryEstimateResult> singlePairShortestPathAStarMutateEstimate(
     }
 
     @Override
-    public Stream<org.neo4j.gds.procedures.algorithms.results.StandardWriteRelationshipsResult> singlePairShortestPathAStarWrite(
+    public Stream<StandardWriteRelationshipsResult> singlePairShortestPathAStarWrite(
         String graphName,
         Map<String, Object> configuration
     ) {
-        return Stream.empty();
+        return writeProcedureFacade.singlePairShortestPathAStar(graphName, configuration);
     }
 
     @Override
@@ -446,11 +451,11 @@ public Stream<MemoryEstimateResult> singlePairShortestPathDijkstraMutateEstimate
     }
 
     @Override
-    public Stream<org.neo4j.gds.procedures.algorithms.results.StandardWriteRelationshipsResult> singlePairShortestPathDijkstraWrite(
+    public Stream<StandardWriteRelationshipsResult> singlePairShortestPathDijkstraWrite(
         String graphName,
         Map<String, Object> configuration
     ) {
-        return Stream.empty();
+        return writeProcedureFacade.singlePairShortestPathDijkstra(graphName, configuration);
     }
 
     @Override
@@ -494,11 +499,11 @@ public Stream<MemoryEstimateResult> singlePairShortestPathYensMutateEstimate(
     }
 
     @Override
-    public Stream<org.neo4j.gds.procedures.algorithms.results.StandardWriteRelationshipsResult> singlePairShortestPathYensWrite(
+    public Stream<StandardWriteRelationshipsResult> singlePairShortestPathYensWrite(
         String graphName,
         Map<String, Object> configuration
     ) {
-        return Stream.empty();
+        return writeProcedureFacade.singlePairShortestPathYens(graphName, configuration);
     }
 
     @Override
@@ -542,11 +547,11 @@ public Stream<MemoryEstimateResult> singleSourceShortestPathDijkstraMutateEstima
     }
 
     @Override
-    public Stream<org.neo4j.gds.procedures.algorithms.results.StandardWriteRelationshipsResult> singleSourceShortestPathDijkstraWrite(
+    public Stream<StandardWriteRelationshipsResult> singleSourceShortestPathDijkstraWrite(
         String graphName,
         Map<String, Object> configuration
     ) {
-        return Stream.empty();
+        return writeProcedureFacade.singleSourceShortestPathDijkstra(graphName, configuration);
     }
 
     @Override
@@ -598,7 +603,7 @@ public Stream<MemoryEstimateResult> spanningTreeStreamEstimate(
 
     @Override
     public Stream<SpanningTreeWriteResult> spanningTreeWrite(String graphName, Map<String, Object> configuration) {
-        return Stream.empty();
+        return writeProcedureFacade.spanningTree(graphName, configuration);
     }
 
     @Override
@@ -650,7 +655,7 @@ public Stream<MemoryEstimateResult> steinerTreeStreamEstimate(
 
     @Override
     public Stream<SteinerWriteResult> steinerTreeWrite(String graphName, Map<String, Object> configuration) {
-        return Stream.empty();
+        return writeProcedureFacade.steinerTree(graphName, configuration);
     }
 
     @Override

procedures/pushback-procedures-facade/src/main/java/org/neo4j/gds/procedures/algorithms/pathfinding/write/BellmanFordWriteResultTransformerBuilder.java

@@ -0,0 +1,40 @@
+/*
+ * Copyright (c) "Neo4j"
+ * Neo4j Sweden AB [http://neo4j.com]
+ *
+ * This file is part of Neo4j.
+ *
+ * Neo4j is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.neo4j.gds.procedures.algorithms.pathfinding.write;
+
+import org.neo4j.gds.api.Graph;
+import org.neo4j.gds.api.GraphStore;
+import org.neo4j.gds.paths.bellmanford.AllShortestPathsBellmanFordWriteConfig;
+import org.neo4j.gds.paths.bellmanford.BellmanFordResult;
+import org.neo4j.gds.procedures.algorithms.pathfinding.BellmanFordWriteResult;
+import org.neo4j.gds.result.TimedAlgorithmResult;
+import org.neo4j.gds.results.ResultTransformer;
+import org.neo4j.gds.results.ResultTransformerBuilder;
+
+import java.util.stream.Stream;
+
+class BellmanFordWriteResultTransformerBuilder implements ResultTransformerBuilder<TimedAlgorithmResult<BellmanFordResult>, Stream<BellmanFordWriteResult>> {
+    BellmanFordWriteResultTransformerBuilder(AllShortestPathsBellmanFordWriteConfig config) {}
+
+    @Override
+    public ResultTransformer<TimedAlgorithmResult<BellmanFordResult>, Stream<BellmanFordWriteResult>> build(Graph graph, GraphStore graphStore) {
+        return ar -> Stream.empty();
+    }
+}

procedures/pushback-procedures-facade/src/main/java/org/neo4j/gds/procedures/algorithms/pathfinding/write/DeltaSteppingWriteResultTransformerBuilder.java

@@ -0,0 +1,40 @@
+/*
+ * Copyright (c) "Neo4j"
+ * Neo4j Sweden AB [http://neo4j.com]
+ *
+ * This file is part of Neo4j.
+ *
+ * Neo4j is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.neo4j.gds.procedures.algorithms.pathfinding.write;
+
+import org.neo4j.gds.api.Graph;
+import org.neo4j.gds.api.GraphStore;
+import org.neo4j.gds.paths.delta.config.AllShortestPathsDeltaWriteConfig;
+import org.neo4j.gds.paths.dijkstra.PathFindingResult;
+import org.neo4j.gds.procedures.algorithms.results.StandardWriteRelationshipsResult;
+import org.neo4j.gds.result.TimedAlgorithmResult;
+import org.neo4j.gds.results.ResultTransformer;
+import org.neo4j.gds.results.ResultTransformerBuilder;
+
+import java.util.stream.Stream;
+
+class DeltaSteppingWriteResultTransformerBuilder implements ResultTransformerBuilder<TimedAlgorithmResult<PathFindingResult>, Stream<StandardWriteRelationshipsResult>> {
+    DeltaSteppingWriteResultTransformerBuilder(AllShortestPathsDeltaWriteConfig config) {}
+
+    @Override
+    public ResultTransformer<TimedAlgorithmResult<PathFindingResult>, Stream<StandardWriteRelationshipsResult>> build(Graph graph, GraphStore graphStore) {
+        return ar -> Stream.empty();
+    }
+}

procedures/pushback-procedures-facade/src/main/java/org/neo4j/gds/procedures/algorithms/pathfinding/write/PCSTWriteResultTransformerBuilder.java

@@ -0,0 +1,43 @@
+/*
+ * Copyright (c) "Neo4j"
+ * Neo4j Sweden AB [http://neo4j.com]
+ *
+ * This file is part of Neo4j.
+ *
+ * Neo4j is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.neo4j.gds.procedures.algorithms.pathfinding.write;
+
+import org.neo4j.gds.api.Graph;
+import org.neo4j.gds.api.GraphStore;
+import org.neo4j.gds.pcst.PCSTWriteConfig;
+import org.neo4j.gds.pricesteiner.PrizeSteinerTreeResult;
+import org.neo4j.gds.procedures.algorithms.pathfinding.PrizeCollectingSteinerTreeWriteResult;
+import org.neo4j.gds.result.TimedAlgorithmResult;
+import org.neo4j.gds.results.ResultTransformer;
+import org.neo4j.gds.results.ResultTransformerBuilder;
+
+import java.util.stream.Stream;
+
+class PCSTWriteResultTransformerBuilder implements ResultTransformerBuilder<TimedAlgorithmResult<PrizeSteinerTreeResult>, Stream<PrizeCollectingSteinerTreeWriteResult>> {
+    PCSTWriteResultTransformerBuilder(PCSTWriteConfig config) {}
+
+    @Override
+    public ResultTransformer<TimedAlgorithmResult<PrizeSteinerTreeResult>, Stream<PrizeCollectingSteinerTreeWriteResult>> build(
+        Graph graph,
+        GraphStore graphStore
+    ) {
+        return ar -> Stream.empty();
+    }
+}