docs: @SuppressWarnings({ "rawtypes" })
      public synchronized void initStreamingSessions(List<String> stores,
                                                     Callable checkpointCallback,
                                                     Callable recoveryCallback,
                                                     boolean allowMerge) {
  
          this.initStreamingSessions(stores, checkpointCallback, recoveryCallback, allowMerge, null);
  
      }