diff --git a/core/src/main/java/org/neo4j/gds/core/loading/SingleTypeRelationshipImporter.java b/core/src/main/java/org/neo4j/gds/core/loading/SingleTypeRelationshipImporter.java index b76f474f16..40e6264d13 100644 --- a/core/src/main/java/org/neo4j/gds/core/loading/SingleTypeRelationshipImporter.java +++ b/core/src/main/java/org/neo4j/gds/core/loading/SingleTypeRelationshipImporter.java @@ -87,6 +87,10 @@ public int typeId() { return this.typeId; } + public boolean skipDanglingRelationships() { + return this.importMetaData.skipDanglingRelationships(); + } + public Collection adjacencyListBuilderTasks(Optional mapper) { return adjacencyBuffer.adjacencyListBuilderTasks(mapper, Optional.empty()); } diff --git a/native-projection/src/main/java/org/neo4j/gds/projection/RelationshipsScannerTask.java b/native-projection/src/main/java/org/neo4j/gds/projection/RelationshipsScannerTask.java index 49821ed8dd..ee8c1fe84b 100644 --- a/native-projection/src/main/java/org/neo4j/gds/projection/RelationshipsScannerTask.java +++ b/native-projection/src/main/java/org/neo4j/gds/projection/RelationshipsScannerTask.java @@ -148,6 +148,7 @@ public void accept(KernelTransaction transaction) { var buffer = new BufferedRelationshipConsumerBuilder() .idMap(idMap) .type(importer.typeId()) + .skipDanglingRelationships(importer.skipDanglingRelationships()) .capacity(scanner.bufferSize()) .build();