Skip to content

Commit daecc35

Browse files
Use rel scan cursor in storage reader
1 parent 8028d7b commit daecc35

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

cypher/4.3.3/storage-engine-adapter/src/main/java/org/neo4j/gds/compat/_433/InMemoryRelationshipScanCursor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727

2828
public class InMemoryRelationshipScanCursor extends AbstractInMemoryRelationshipScanCursor {
2929

30-
InMemoryRelationshipScanCursor(CypherGraphStore graphStore, TokenHolders tokenHolders) {
30+
public InMemoryRelationshipScanCursor(CypherGraphStore graphStore, TokenHolders tokenHolders) {
3131
super(graphStore, tokenHolders);
3232
}
3333

cypher/4.3.3/storage-engine-adapter/src/main/java/org/neo4j/internal/recordstorage/InMemoryStorageReader433.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import org.neo4j.counts.CountsAccessor;
2424
import org.neo4j.gds.compat._433.InMemoryNodeCursor;
2525
import org.neo4j.gds.compat._433.InMemoryPropertyCursor;
26+
import org.neo4j.gds.compat._433.InMemoryRelationshipScanCursor;
2627
import org.neo4j.gds.compat._433.InMemoryRelationshipTraversalCursor;
2728
import org.neo4j.gds.core.cypher.CypherGraphStore;
2829
import org.neo4j.internal.schema.constraints.IndexBackedConstraintDescriptor;
@@ -90,6 +91,6 @@ public StorageRelationshipTraversalCursor allocateRelationshipTraversalCursor(Cu
9091

9192
@Override
9293
public StorageRelationshipScanCursor allocateRelationshipScanCursor(CursorContext cursorContext) {
93-
return new RecordRelationshipScanCursor(null, cursorContext);
94+
return new InMemoryRelationshipScanCursor(graphStore, tokenHolders);
9495
}
9596
}

cypher/api/storage-engine-adapter/src/main/java/org/neo4j/internal/recordstorage/AbstractInMemoryStorageReader.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -221,7 +221,7 @@ public AllNodeScan allNodeScan() {
221221

222222
@Override
223223
public AllRelationshipsScan allRelationshipScan() {
224-
return new RecordRelationshipScan();
224+
return new InMemoryRelationshipScan() ;
225225
}
226226

227227
@Override

0 commit comments

Comments
 (0)