@@ -353,29 +353,29 @@ public boolean hasRelationshipType(RelationshipType relationshipType) {
353353 public long relationshipCount () {
354354 long sum = 0L ;
355355 for (var relationship : relationships .values ()) {
356- long elementCount = relationship .forwardTopology ().elementCount ();
356+ long elementCount = relationship .topology ().elementCount ();
357357 sum += elementCount ;
358358 }
359359 return sum ;
360360 }
361361
362362 @ Override
363363 public long relationshipCount (RelationshipType relationshipType ) {
364- return relationships .get (relationshipType ).forwardTopology ().elementCount ();
364+ return relationships .get (relationshipType ).topology ().elementCount ();
365365 }
366366
367367 @ Override
368368 public boolean hasRelationshipProperty (RelationshipType relType , String propertyKey ) {
369369 return Optional .ofNullable (relationships .get (relType ))
370- .flatMap (SingleTypeRelationshipImportResult ::forwardProperties )
370+ .flatMap (SingleTypeRelationshipImportResult ::properties )
371371 .map (propertyStore -> propertyStore .containsKey (propertyKey ))
372372 .orElse (false );
373373 }
374374
375375 @ Override
376376 public ValueType relationshipPropertyType (String propertyKey ) {
377377 return relationships .values ().stream ()
378- .flatMap (relationship -> relationship .forwardProperties ().stream ())
378+ .flatMap (relationship -> relationship .properties ().stream ())
379379 .filter (propertyStore -> propertyStore .containsKey (propertyKey ))
380380 .map (propertyStore -> propertyStore .get (propertyKey ).valueType ())
381381 .findFirst ()
@@ -385,23 +385,23 @@ public ValueType relationshipPropertyType(String propertyKey) {
385385 @ Override
386386 public Set <String > relationshipPropertyKeys () {
387387 return relationships .values ().stream ()
388- .flatMap (relationship -> relationship .forwardProperties ().stream ())
388+ .flatMap (relationship -> relationship .properties ().stream ())
389389 .flatMap (propertyStore -> propertyStore .keySet ().stream ())
390390 .collect (Collectors .toSet ());
391391 }
392392
393393 @ Override
394394 public Set <String > relationshipPropertyKeys (RelationshipType relationshipType ) {
395395 return Optional .ofNullable (relationships .get (relationshipType ))
396- .flatMap (SingleTypeRelationshipImportResult ::forwardProperties )
396+ .flatMap (SingleTypeRelationshipImportResult ::properties )
397397 .map (RelationshipPropertyStore ::keySet )
398398 .orElseGet (Set ::of );
399399 }
400400
401401 @ Override
402402 public RelationshipProperty relationshipPropertyValues (RelationshipType relationshipType , String propertyKey ) {
403403 return Optional .ofNullable (relationships .get (relationshipType ))
404- .flatMap (SingleTypeRelationshipImportResult ::forwardProperties )
404+ .flatMap (SingleTypeRelationshipImportResult ::properties )
405405 .map (propertyStore -> propertyStore .get (propertyKey ))
406406 .orElseGet (() -> RelationshipPropertyStore .empty ().get (propertyKey ));
407407 }
@@ -416,8 +416,8 @@ public void addRelationshipType(
416416 ) {
417417 updateGraphStore (graphStore -> {
418418 graphStore .relationships .computeIfAbsent (relationshipType , __ -> {
419- var builder = ImmutableSingleTypeRelationshipImportResult .builder ()
420- .forwardTopology (relationships .topology ())
419+ var builder = SingleTypeRelationshipImportResult .builder ()
420+ .topology (relationships .topology ())
421421 .direction (direction );
422422
423423 var relationshipSchemaEntry = schema ()
@@ -440,7 +440,7 @@ public void addRelationshipType(
440440 Aggregation .NONE
441441 )).build ();
442442
443- builder .forwardProperties (properties );
443+ builder .properties (properties );
444444
445445 var valueType = ValueTypes .fromNumberType (relationshipPropertyType .get ());
446446 relationshipSchemaEntry .addProperty (propertyKey , RelationshipPropertySchema .of (
@@ -464,8 +464,8 @@ public DeletionResult deleteRelationships(RelationshipType relationshipType) {
464464 Optional .ofNullable (graphStore .relationships .remove (relationshipType ))
465465 .ifPresentOrElse (
466466 relationship -> {
467- builder .deletedRelationships (relationship .forwardTopology ().elementCount ());
468- relationship .forwardProperties ().ifPresent (properties -> {
467+ builder .deletedRelationships (relationship .topology ().elementCount ());
468+ relationship .properties ().ifPresent (properties -> {
469469 properties
470470 .values ()
471471 .forEach (property -> builder .putDeletedProperty (
@@ -510,7 +510,7 @@ public CSRGraph getUnion() {
510510 var relationship = entry .getValue ();
511511
512512 return relationship
513- .forwardProperties ()
513+ .properties ()
514514 .map (properties -> properties .keySet ().stream ().map (Optional ::of ))
515515 .orElseGet (() -> Stream .of (Optional .empty ()))
516516 .map (propertyKey -> createGraph (nodeLabels (), relationshipType , propertyKey ));
@@ -556,8 +556,8 @@ public CompositeRelationshipIterator getCompositeRelationshipIterator(
556556 }
557557
558558 var relationship = relationships .get (relationshipType );
559- var adjacencyList = relationship .forwardTopology ().adjacencyList ();
560- var relationshipPropertyStore = relationship .forwardProperties ().orElse (RelationshipPropertyStore .empty ());
559+ var adjacencyList = relationship .topology ().adjacencyList ();
560+ var relationshipPropertyStore = relationship .properties ().orElse (RelationshipPropertyStore .empty ());
561561
562562 var properties = propertyKeys .isEmpty ()
563563 ? CSRCompositeRelationshipIterator .EMPTY_PROPERTIES
@@ -587,9 +587,9 @@ private void releaseInternals() {
587587 closeables .accept ((AutoCloseable ) this .nodes );
588588 }
589589 this .relationships .values ().forEach (relationship -> {
590- closeables .add (relationship .forwardTopology ().adjacencyList ());
590+ closeables .add (relationship .topology ().adjacencyList ());
591591 relationship
592- .forwardProperties ()
592+ .properties ()
593593 .stream ()
594594 .flatMap (properties -> properties .values ().stream ())
595595 .forEach (property -> closeables .add (property .values ().propertiesList ()));
@@ -700,15 +700,15 @@ private CSRGraph createGraphFromRelationshipType(
700700
701701 var relationship = relationships .get (relationshipType );
702702 var properties = maybeRelationshipProperty .map (propertyKey -> relationship
703- .forwardProperties ()
703+ .properties ()
704704 .map (props -> props .get (propertyKey ).values ())
705705 .orElseThrow (() -> new IllegalArgumentException ("Relationship property key not present in graph: " + propertyKey )));
706706
707707 var initialGraph = HugeGraph .create (
708708 nodes ,
709709 graphSchema ,
710710 filteredNodeProperties ,
711- relationship .forwardTopology (),
711+ relationship .topology (),
712712 properties
713713 );
714714
0 commit comments