in src/main/java/software/amazon/neptune/csv2rdf/PropertyGraph2RdfMapper.java [189:212]
public List<Statement> mapToStatements(NeptunePropertyGraphEdge edge) {
List<Statement> statements = new ArrayList<>();
PropertyGraphEdge2RdfMapping edgeMapper = mapping.getEdge2RdfMapping();
// the edge itself
if (edge.hasLabel()) {
// edge ID goes into graph position
statements.add(
edgeMapper.createRelationStatement(edge.getFrom(), edge.getLabel(), edge.getTo(), edge.getId()));
} else {
statements.add(edgeMapper.createRelationStatement(edge.getFrom(), edge.getTo(), edge.getId()));
}
// append edge properties
for (NeptuneCsvSingleValuedUserDefinedProperty userDefinedProperty : edge.getUserDefinedProperties()) {
statements.add(edgeMapper.createLiteralStatement(edge.getId(), userDefinedProperty.getName(),
userDefinedProperty.getValue(), userDefinedProperty.getDataType()));
}
return statements;
}