in src/main/java/software/amazon/neptune/csv2rdf/UriPostTransformer.java [100:119]
private void extractUriTransformationResourcesAndReplacementValues(File file, String baseUri) {
log.info("--> Extracting URI transformation resources and replacement values from " + file.getName() + "...");
try (FileInputStream fis = new FileInputStream(file)) {
RDFParser rdfParser = Rio.createParser(PropertyGraph2RdfConverter.RDF_FORMAT);
rdfParser.setRDFHandler(new AbstractRDFHandler() {
@Override
public void handleStatement(Statement statement) {
register(statement);
}
});
rdfParser.parse(fis, baseUri);
} catch (UnsupportedRDFormatException | RDFHandlerException | RDFParseException | IOException e) {
throw new Csv2RdfException("Extracting URI transformation resources and replacement values from "
+ file.getAbsolutePath() + " failed.", e);
}
}