@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;
    }
  }
}

@ 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 ; } } }
transfers the data which has been committed till windowid to data files .
