question: @ Override public void committed ( long committedWindowId ) throws IOException { LOG . debug ( "data manager committed {}" , committedWindowId ) ; for ( Long currentWindow : savedWindows . keySet ( ) ) { if ( currentWindow <= largestWindowAddedToTransferQueue ) { continue ; } if ( currentWindow <= committedWindowId ) { LOG . debug ( "to transfer {}" , currentWindow ) ; largestWindowAddedToTransferQueue = currentWindow ; windowsToTransfer . add ( currentWindow ) ; } else { break ; } } }
target:  Transfers the data which has been committed till windowId to data files.