public void map()

in src/main/java/software/amazon/neptune/csv2rdf/PropertyGraph2RdfMapper.java [133:160]

• 22 lines of code
• 4 McCabe index (conditional complexity)

	public void map(final File propertyGraphInFile, File rdfOutFile) {

		log.info("-> Converting input file {}...", propertyGraphInFile.getName());

		RDFWriter rdfWriter = null;
		try (NeptuneCsvInputParser inputParser = new NeptuneCsvInputParser(propertyGraphInFile);
				FileOutputStream fos = new FileOutputStream(rdfOutFile)) {

			rdfWriter = Rio.createWriter(PropertyGraph2RdfConverter.RDF_FORMAT, fos);
			rdfWriter.startRDF();
			rdfWriter.handleNamespace("vertex", mapping.getVertexNamespace());
			rdfWriter.handleNamespace("edge", mapping.getEdgeNamespace());
			rdfWriter.handleNamespace("vertexprop", mapping.getVertexPropertyNamespace());
			rdfWriter.handleNamespace("edgeprop", mapping.getEdgePropertyNamespace());

			while (inputParser.hasNext()) {
				List<Statement> statements = mapToStatements(inputParser.next());
				for (Statement statement : statements) {
					rdfWriter.handleStatement(statement);
				}
			}

			rdfWriter.endRDF();
		} catch (UnsupportedRDFormatException | RDFHandlerException | IOException e) {

			throw new Csv2RdfException("Conversion of file " + propertyGraphInFile.getAbsolutePath() + " failed.", e);
		}
	}