src/main/java/com/amazonaws/services/neptune/rdf/io/EnhancedNQuadsWriter.java [32:55]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        super(writer.writer());
        this.writer = writer;
        this.prefixes = prefixes;
    }

    @Override
    public void handleStatement(Statement statement) throws RDFHandlerException {
        prefixes.parse(statement.getSubject().stringValue(), this);
        prefixes.parse(statement.getPredicate().toString(), this);
        prefixes.parse(statement.getObject().stringValue(), this);

        Resource context = statement.getContext();
        if (context != null){
            prefixes.parse(context.stringValue(), this);
        }

        writer.startCommit();
        super.handleStatement(statement);
        writer.endCommit();

        status.update();
    }

    @Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/amazonaws/services/neptune/rdf/io/EnhancedTurtleWriter.java [33:57]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        super(writer.writer());
        this.writer = writer;
        this.prefixes = prefixes;
    }

    @Override
    public void handleStatement(Statement statement) throws RDFHandlerException {

        prefixes.parse(statement.getSubject().stringValue(), this);
        prefixes.parse(statement.getPredicate().toString(), this);
        prefixes.parse(statement.getObject().stringValue(), this);

        Resource context = statement.getContext();
        if (context != null){
            prefixes.parse(context.stringValue(), this);
        }

        writer.startCommit();
        super.handleStatement(statement);
        writer.endCommit();

        status.update();
    }

    @Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -