Skip to content

Commit 98b87e9

Browse files
committed
Set direction in CypherAggregation and GraphStoreUtil
1 parent 86031fd commit 98b87e9

File tree

3 files changed

+5
-0
lines changed

3 files changed

+5
-0
lines changed

core/src/main/java/org/neo4j/gds/core/loading/CSRGraphStoreUtil.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -98,6 +98,7 @@ public static CSRGraphStore createFromGraph(
9898
SingleTypeRelationshipImportResult.builder()
9999
.topology(relationships.topology())
100100
.properties(relationshipProperties)
101+
.direction(direction)
101102
.build()
102103
).build();
103104

core/src/test/java/org/neo4j/gds/config/WriteConfigTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,8 +28,10 @@
2828
import org.neo4j.gds.core.huge.DirectIdMap;
2929
import org.neo4j.gds.core.loading.GraphStoreBuilder;
3030
import org.neo4j.gds.core.loading.ImmutableStaticCapabilities;
31+
import org.neo4j.gds.core.loading.RelationshipImportResult;
3132

3233
import java.util.List;
34+
import java.util.Map;
3335

3436
import static org.assertj.core.api.Assertions.assertThatCode;
3537

@@ -46,6 +48,7 @@ void validateGraphStoreCapabilities(boolean isBackedByDatabase) {
4648
.capabilities(ImmutableStaticCapabilities.of(isBackedByDatabase))
4749
.schema(GraphSchema.empty())
4850
.nodes(new DirectIdMap(0))
51+
.relationshipImportResult(RelationshipImportResult.of(Map.of()))
4952
.concurrency(1)
5053
.build();
5154

cypher-aggregation/src/main/java/org/neo4j/gds/projection/CypherAggregation.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -661,6 +661,7 @@ private void buildRelationshipsWithProperties(
661661
SingleTypeRelationshipImportResult.builder()
662662
.topology(topology)
663663
.properties(propertyStore)
664+
.direction(Direction.DIRECTED)
664665
.build()
665666
);
666667
});

0 commit comments

Comments
 (0)