hdfs-protolib/src/main/java/com/streamsets/pipeline/stage/destination/hdfs/writer/RecordWriterManager.java
public void issueCachedEvents() throws IOException {
    Path closedPath;
    while((closedPath = closedPaths.poll()) != null) {
      produceCloseFileEvent(fs, closedPath);
    }
  }
public void issueCachedEvents() throws IOException {
    Path closedPath;
    while((closedPath = closedPaths.poll()) != null) {
      produceCloseFileEvent(fs, closedPath);
    }
  }
public void issueCachedEvents ( ) throws IOException { Path closedPath ; while ( ( closedPath = closedPaths . poll ( ) ) != null ) { produceCloseFileEvent ( fs , closedPath ) ; } }
Produce events that were cached during the batch processing.
Produce events that were cached during the batch processing .