azure-lib/src/main/java/com/streamsets/pipeline/stage/destination/datalake/writer/DataLakeGeneratorManager.java
public void issueCachedEvents() throws IOException {
    String closedPath;
    while((closedPath = closedPaths.poll()) != null) {
      produceCloseFileEvent(closedPath);
    }
  }
public void issueCachedEvents() throws IOException {
    String closedPath;
    while((closedPath = closedPaths.poll()) != null) {
      produceCloseFileEvent(closedPath);
    }
  }
public void issueCachedEvents ( ) throws IOException { String closedPath ; while ( ( closedPath = closedPaths . poll ( ) ) != null ) { produceCloseFileEvent ( closedPath ) ; } }
Produce events that were cached during the batch processing.
Produce events that were cached during the batch processing .