Skip to content

Commit 7ee76c2

Browse files
committed
Pass relationshipType token to read api in rel property reader
1 parent c540507 commit 7ee76c2

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

native-projection/src/main/java/org/neo4j/gds/projection/RelationshipsScannerTask.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,7 @@ public void accept(KernelTransaction transaction) {
156156
buffers[idx.getAndIncrement()] = buffer;
157157

158158
PropertyReader<Reference> propertyReader = importer.loadProperties()
159-
? storeBackedPropertyReader(transaction)
159+
? storeBackedPropertyReader(transaction, importer.typeId())
160160
: emptyPropertyReader();
161161

162162
return importer.threadLocalImporter(
@@ -208,7 +208,7 @@ private static PropertyReader<Reference> emptyPropertyReader() {
208208
}
209209

210210
@NotNull
211-
private static PropertyReader<Reference> storeBackedPropertyReader(KernelTransaction kernelTransaction) {
211+
private static PropertyReader<Reference> storeBackedPropertyReader(KernelTransaction kernelTransaction, int relationshipTypeId) {
212212
return (producer, propertyKeyIds, defaultPropertyValues, aggregations, atLeastOnePropertyToLoad) -> {
213213
long[][] properties = new long[propertyKeyIds.length][producer.numberOfElements()];
214214
if (atLeastOnePropertyToLoad) {
@@ -222,6 +222,7 @@ private static PropertyReader<Reference> storeBackedPropertyReader(KernelTransac
222222
producer.forEach((index, relationshipReference, propertyReference) -> {
223223
read.relationshipProperties(
224224
relationshipReference,
225+
relationshipTypeId,
225226
propertyReference,
226227
PropertySelection.ALL_PROPERTIES,
227228
pc

0 commit comments

Comments
 (0)