private void loadEntities()

in ytdb/src/main/java/com/youtrackdb/ldbc/ytdb/loader/YtdbLoader.java [114:135]

20 lines of code
3 McCabe index (conditional complexity)


    private <T> void loadEntities(Path dir, String filename, String entityLabel,
                                  java.util.function.Function<String[], T> parser,
                                  java.util.function.Consumer<List<T>> inserter) {
        try {
            Path csvFile = dir.resolve(filename);
            if (!Files.exists(csvFile)) {
                log.warn("File not found: {}", csvFile);
                return;
            }

            var processor = new CsvProcessor<T>(BATCH_SIZE);
            long count = processor.process(csvFile,
                    parser::apply,
                    inserter::accept
            );

            log.info("Loaded {} {} entities", count, entityLabel);
        } catch (Exception e) {
            log.error("Failed to load {}: {}", entityLabel, e.getMessage(), e);
            throw new RuntimeException("Failed to load " + entityLabel, e);
        }
    }