protected synchronized void dropTmpFiles(){
  if (writerInstances != null) {
    for (    Entry<String,EventWriterWrapper> entry : writerInstances.entrySet()) {
      dropTmpFile(entry.getValue());
    }
  }
  if (defaultWriterInstance != null) {
    dropTmpFile(defaultWriterInstance);
  }
  try {
    for (    BatchListener listener : listeners) {
      listener.onFilesDropped(partitionKey,currentFolder);
    }
  }
 catch (  Exception e) {
    LOGGER.log(Level.SEVERE,e.toString(),e);
  }
  cleanup();
}

protected synchronized void dropTmpFiles ( ) { if ( writerInstances != null ) { for ( Entry < String , EventWriterWrapper > entry : writerInstances . entrySet ( ) ) { dropTmpFile ( entry . getValue ( ) ) ; } } if ( defaultWriterInstance != null ) { dropTmpFile ( defaultWriterInstance ) ; } try { for ( BatchListener listener : listeners ) { listener . onFilesDropped ( partitionKey , currentFolder ) ; } } catch ( Exception e ) { LOGGER . log ( Level . SEVERE , e . toString ( ) , e ) ; } cleanup ( ) ; }
drop current tmp file
