private void closeCurrentPartFile ( ) throws Exception { if ( isWriterOpen ) { writer . close ( ) ; isWriterOpen = false ; } if ( currentPartPath != null ) { Path inProgressPath = getInProgressPathFor ( currentPartPath ) ; Path pendingPath = getPendingPathFor ( currentPartPath ) ; fs . rename ( inProgressPath , pendingPath ) ; LOG . debug ( "Moving in-progress bucket {} to pending file {}" , inProgressPath , pendingPath ) ; this . bucketState . pendingFiles . add ( currentPartPath . toString ( ) ) ; } }
Closes the current part file .