code: @SuppressWarnings({ "rawtypes" })
      public synchronized void initStreamingSessions(List<String> stores,
                                                     Callable checkpointCallback,
                                                     Callable recoveryCallback,
                                                     boolean allowMerge) {
  
          this.initStreamingSessions(stores, checkpointCallback, recoveryCallback, allowMerge, null);
  
      }
docs: *
  @param stores - the list of name of the stores to be streamed to
  
  
  @param checkpointCallback - the callback that allows for the user to
  record the progress, up to the last event delivered. This callable
  would be invoked every so often internally.
  
  @param recoveryCallback - the callback that allows the user to rewind the
  upstream to the position recorded by the last complete call on
  checkpointCallback whenever an exception occurs during the
  streaming session.
  
  @param allowMerge - whether to allow for the streaming event to be merged
  with online writes. If not, all online writes since the completion
  of the last streaming session will be lost at the end of the
  current streaming session.