in ytdb/src/main/java/com/youtrackdb/ldbc/ytdb/loader/YtdbLoader.java [286:307]
private void loadSimpleEdge(Path dir, String filename, String edgeLabel,
String fromLabel, String toLabel) {
try {
Path csvFile = dir.resolve(filename);
if (!Files.exists(csvFile)) {
log.warn("File not found: {}", csvFile);
return;
}
var processor = new CsvProcessor<SimpleEdge>(BATCH_SIZE);
long count = processor.process(csvFile,
SimpleEdge::parse,
batch -> insertSimpleEdges(batch, edgeLabel, fromLabel, toLabel)
);
log.info("Loaded {} {} edges", count, edgeLabel);
} catch (Exception e) {
log.error("Failed to load {} edges: {}", edgeLabel, e.getMessage(), e);
throw new RuntimeException("Failed to load " + edgeLabel + " edges", e);
}
}