Skip to content

Commit 68383d4

Browse files
adamnschlassewesth
andcommitted
Support multi-algo dijkstra
Co-Authored-By: Lasse Westh-Nielsen <lassewesth@gmail.com>
1 parent 0267204 commit 68383d4

File tree

1 file changed

+3
-10
lines changed
  • applications/algorithms/path-finding/src/main/java/org/neo4j/gds/applications/algorithms/pathfinding

1 file changed

+3
-10
lines changed

applications/algorithms/path-finding/src/main/java/org/neo4j/gds/applications/algorithms/pathfinding/StorePathsSideEffect.java

Lines changed: 3 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -67,29 +67,22 @@ public Optional<RelationshipsWritten> process(GraphResources graphResources, Opt
6767
return new ExportedRelationship(
6868
pathResult.sourceNode(),
6969
pathResult.targetNode(),
70-
createValues(graphResources.graph(), pathResult)
70+
createValues(pathResult)
7171
);
7272
});
7373

74-
resultStore.add(JobId.parse("banana"), new ResultStoreEntry.RelationshipStream(
74+
resultStore.add(JobId.parse(this.relationshipTypeAsString), new ResultStoreEntry.RelationshipStream(
7575
relationshipTypeAsString, propertyKeys, propertyTypes, relationshipStream, graphResources.graph()::toOriginalNodeId));
7676

7777
return new RelationshipsWritten(relCounter.get());
7878
});
7979
}
8080

81-
private Value[] createValues(IdMap idMap, PathResult pathResult) {
81+
private Value[] createValues(PathResult pathResult) {
8282
return new Value[]{
8383
Values.doubleValue(pathResult.totalCost()),
8484
Values.longArray(pathResult.nodeIds()),
8585
Values.doubleArray(pathResult.costs())
8686
};
8787
}
88-
89-
private long[] toOriginalIds(IdMap idMap, long[] internalIds) {
90-
for (int i = 0; i < internalIds.length; i++) {
91-
internalIds[i] = idMap.toOriginalNodeId(internalIds[i]);
92-
}
93-
return internalIds;
94-
}
9588
}

0 commit comments

Comments
 (0)