src/main/java/com/amazonaws/services/neptune/propertygraph/io/NeptuneStreamsJsonPropertyGraphPrinter.java [112:134]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        writer.startCommit();
    }

    @Override
    public void printEndRow() throws IOException {
        generator.flush();
        writer.endCommit();
    }

    @Override
    public void close() throws Exception {
        generator.close();
        writer.close();
    }

    private void printRecord(String id, String streamOperation, String key, Object value, DataType dataType) throws IOException {
        printRecord(id, streamOperation, key, value, dataType, null, null);
    }

    private void printRecord(String id, String streamOperation, String key, Object value, DataType dataType, String from, String to) throws IOException {

        writer.startOp();
        generator.writeStartObject();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/amazonaws/services/neptune/propertygraph/io/NeptuneStreamsSimpleJsonPropertyGraphPrinter.java [114:136]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        writer.startCommit();
    }

    @Override
    public void printEndRow() throws IOException {
        generator.flush();
        writer.endCommit();
    }

    @Override
    public void close() throws Exception {
        generator.close();
        writer.close();
    }

    private void printRecord(String id, String streamOperation, String key, Object value, DataType dataType) throws IOException {
        printRecord(id, streamOperation, key, value, dataType, null, null);
    }

    private void printRecord(String id, String streamOperation, String key, Object value, DataType dataType, String from, String to) throws IOException {

        writer.startOp();
        generator.writeStartObject();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -