public Future<ReplDBMSHeader> flush(String eventId) throws InterruptedException, ReplicatorException {
  logger.info("Scheduling pipeline flush on event ID: " + eventId);
  return watchForProcessedEventId(eventId);
}

public Future < ReplDBMSHeader > flush ( String eventId ) throws InterruptedException , ReplicatorException { logger . info ( "Scheduling pipeline flush on event ID: " + eventId ) ; return watchForProcessedEventId ( eventId ) ; }
wait until the log reaches at least a particular event id .
