in ytdb/src/main/java/com/youtrackdb/ldbc/ytdb/loader/YtdbLoader.java [336:350]
private void insertKnowsEdges(List<KnowsEdge> batch) {
traversal.executeInTx(g -> {
for (KnowsEdge edge : batch) {
// Bidirectional relationship
g.V().has(LdbcSchema.PERSON, LdbcSchema.ID, edge.person1Id())
.addE(LdbcSchema.KNOWS)
.to(V().has(LdbcSchema.PERSON, LdbcSchema.ID, edge.person2Id()))
.property(LdbcSchema.CREATION_DATE, edge.creationDate()).iterate();
g.V().has(LdbcSchema.PERSON, LdbcSchema.ID, edge.person2Id())
.addE(LdbcSchema.KNOWS)
.to(V().has(LdbcSchema.PERSON, LdbcSchema.ID, edge.person1Id()))
.property(LdbcSchema.CREATION_DATE, edge.creationDate()).iterate();
}
});
}