@Override
    public void close() throws IOException {
        wrappedSegmentOutputStream.close();
    }
Insert segment markers after the header and after every record.
stroom-pipeline/src/main/java/stroom/pipeline/writer/StreamOutput.java