@ AfterBatch public void afterDeliver ( ) { SegmentStream nodeStream = _nodeStream ; if ( nodeStream != null ) { if ( _isBlobDirty ) { _isBlobDirty = false ; // nodeStream.flush(null); nodeStream . fsync ( Result . ignore ( ) ) ; } else { nodeStream . flush ( Result . ignore ( ) ) ; } } /* if (blobWriter != null) { try { blobWriter.flushSegment(); } catch (IOException e) { e.printStackTrace(); } } */ }
Flushes the stream after a batch of writes .