import org.apache.any23.Any23; import org.apache.any23.extractor.csv.CSVExtractorFactory; import org.apache.any23.source.DocumentSource; import org.apache.any23.source.FileDocumentSource; import org.apache.any23.writer.NTriplesWriter; import org.openrdf.repository.Repository; import org.openrdf.repository.sail.SailRepository; import org.openrdf.sail.memory.MemoryStore; import java.io.File; public class CSVProcessor { public static void main(String[] args) { try { Any23 runner = new Any23(); CSVExtractorFactory csvExtractorFactory = CSVExtractorFactory.createDefault(); File csvFile = new File("path/to/csv/file.csv"); DocumentSource csvSource = new FileDocumentSource(csvFile); Repository repository = new SailRepository(new MemoryStore()); repository.initialize(); NTriplesWriter writer = new NTriplesWriter(repository.getConnection().getOutputStream()); runner.extract(csvExtractorFactory, csvSource, writer); repository.getConnection().close(); repository.shutDown(); } catch (Exception e) { e.printStackTrace(); } } }