public void handleStatement()

in src/main/java/com/amazonaws/services/neptune/rdf/io/NeptuneStreamsSimpleJsonNQuadsWriter.java [90:143]
32 lines of code
2 McCabe index (conditional complexity)

    public void handleStatement(Statement statement) throws RDFHandlerException {

        try {
            outputWriter.startCommit();

            generator.writeStartObject();

            generator.writeStringField("id", "");
            generator.writeStringField("from", "");
            generator.writeStringField("to", "");

            generator.writeStringField("type", "");
            generator.writeStringField("key", "");
            generator.writeStringField("value", "");
            generator.writeStringField("dataType", "");

//            generator.writeStringField("s", getValue(statement.getSubject()));
//            generator.writeStringField("p", getValue(statement.getPredicate()));
//            generator.writeStringField("o", getValue(statement.getObject()));
//
//            if (statement.getContext() != null) {
//                generator.writeStringField("g", getValue(statement.getContext()));
//            } else {
//                generator.writeStringField("g", "");
//            }

            generator.writeStringField("s", "");
            generator.writeStringField("p", "");
            generator.writeStringField("o", "");
            generator.writeStringField("g", "");

            generator.writeFieldName("stmt");

            StringWriter stringWriter = new StringWriter();
            NQuadsWriter nQuadsWriter = new NQuadsWriter(stringWriter);
            nQuadsWriter.startRDF();
            nQuadsWriter.handleStatement(statement);
            nQuadsWriter.endRDF();
            generator.writeString(stringWriter.toString().replaceAll(REGEX_LAST_NEWLINE, ""));

            generator.writeStringField("op", "ADD");
            generator.writeEndObject();
            generator.writeRaw(outputWriter.lineSeparator());
            generator.flush();

            outputWriter.endCommit();

            status.update();


        } catch (IOException e) {
            throw new RDFHandlerException(e);
        }
    }