Merge pull request #10352 from neo-technology/🍰_graph_store_stream

🍰 graph store stream

Author: DarthMax

applications/graph-store-catalog-results/src/main/java/org/neo4j/gds/applications/graphstorecatalog/GraphStreamNodePropertiesResult.java

@@ -21,16 +21,10 @@
 
 import java.util.List;
 
-public class GraphStreamNodePropertiesResult {
-    public final long nodeId;
-    public final String nodeProperty;
-    public final Object propertyValue;
-    public final List<String> nodeLabels;
-
-    public GraphStreamNodePropertiesResult(long nodeId, String nodeProperty, Object propertyValue, List<String> nodeLabels) {
-        this.nodeId = nodeId;
-        this.nodeProperty = nodeProperty;
-        this.propertyValue = propertyValue;
-        this.nodeLabels = nodeLabels;
-    }
+public record GraphStreamNodePropertiesResult(
+    long nodeId,
+    String nodeProperty,
+    Object propertyValue,
+    List<String> nodeLabels
+) {
 }

applications/graph-store-catalog-results/src/main/java/org/neo4j/gds/applications/graphstorecatalog/GraphStreamNodePropertyResult.java

@@ -21,14 +21,9 @@
 
 import java.util.List;
 
-public class GraphStreamNodePropertyResult {
-    public final long nodeId;
-    public final Object propertyValue;
-    public final List<String> nodeLabels;
-
-    public GraphStreamNodePropertyResult(long nodeId, Object propertyValue, List<String> nodeLabels) {
-        this.nodeId = nodeId;
-        this.propertyValue = propertyValue;
-        this.nodeLabels = nodeLabels;
-    }
+public record GraphStreamNodePropertyResult(
+    long nodeId,
+    Object propertyValue,
+    List<String> nodeLabels
+){
 }

applications/graph-store-catalog-results/src/main/java/org/neo4j/gds/applications/graphstorecatalog/GraphStreamRelationshipPropertiesResult.java

@@ -19,24 +19,11 @@
  */
 package org.neo4j.gds.applications.graphstorecatalog;
 
-public class GraphStreamRelationshipPropertiesResult {
-    public final long sourceNodeId;
-    public final long targetNodeId;
-    public final String relationshipType;
-    public final String relationshipProperty;
-    public final Number propertyValue;
-
-    public GraphStreamRelationshipPropertiesResult(
-        long sourceNodeId,
-        long targetNodeId,
-        String relationshipType,
-        String relationshipProperty,
-        Number propertyValue
-    ) {
-        this.sourceNodeId = sourceNodeId;
-        this.targetNodeId = targetNodeId;
-        this.relationshipType = relationshipType;
-        this.relationshipProperty = relationshipProperty;
-        this.propertyValue = propertyValue;
-    }
+public record GraphStreamRelationshipPropertiesResult(
+    long sourceNodeId,
+    long targetNodeId,
+    String relationshipType,
+    String relationshipProperty,
+    Number propertyValue
+) {
 }

applications/graph-store-catalog-results/src/main/java/org/neo4j/gds/applications/graphstorecatalog/GraphStreamRelationshipPropertyResult.java

@@ -19,21 +19,10 @@
  */
 package org.neo4j.gds.applications.graphstorecatalog;
 
-public class GraphStreamRelationshipPropertyResult {
-    public final long sourceNodeId;
-    public final long targetNodeId;
-    public final String relationshipType;
-    public final Number propertyValue;
-
-    public GraphStreamRelationshipPropertyResult(
-        long sourceNodeId,
-        long targetNodeId,
-        String relationshipType,
-        Number propertyValue
-    ) {
-        this.sourceNodeId = sourceNodeId;
-        this.targetNodeId = targetNodeId;
-        this.relationshipType = relationshipType;
-        this.propertyValue = propertyValue;
-    }
+public record GraphStreamRelationshipPropertyResult(
+    long sourceNodeId,
+    long targetNodeId,
+    String relationshipType,
+    Number propertyValue
+) {
 }

applications/graph-store-catalog-results/src/main/java/org/neo4j/gds/applications/graphstorecatalog/TopologyResult.java

@@ -19,37 +19,9 @@
  */
 package org.neo4j.gds.applications.graphstorecatalog;
 
-import java.util.Objects;
-
-import static org.neo4j.gds.utils.StringFormatting.formatWithLocale;
-
-public class TopologyResult {
-    public final long sourceNodeId;
-    public final long targetNodeId;
-    public final String relationshipType;
-
-    public TopologyResult(long sourceNodeId, long targetNodeId, String relationshipType) {
-        this.sourceNodeId = sourceNodeId;
-        this.targetNodeId = targetNodeId;
-        this.relationshipType = relationshipType;
-    }
-
-    @Override
-    public String toString() {
-        return formatWithLocale("TopologyResult(%d, %d, type: %s)", sourceNodeId, targetNodeId, relationshipType);
-    }
-
-    @Override
-    public boolean equals(Object o) {
-        if (this == o) return true;
-        if (o == null || getClass() != o.getClass()) return false;
-        TopologyResult that = (TopologyResult) o;
-        return sourceNodeId == that.sourceNodeId && targetNodeId == that.targetNodeId && relationshipType.equals(
-            that.relationshipType);
-    }
-
-    @Override
-    public int hashCode() {
-        return Objects.hash(sourceNodeId, targetNodeId, relationshipType);
-    }
+public record TopologyResult(
+    long sourceNodeId,
+    long targetNodeId,
+    String relationshipType
+) {
 }