code: @Override
    public Object put(List<Map.Entry> batch) throws InterruptedException {
      if (initializeClusterSource()) {
        return clusterSource.put(batch);
      }
      return null;
    }
docs: Writes batch of data to the source
  @param batch
  @throws InterruptedException