docs: public Object persist(final Committer committer) throws InterruptedException
    {
      try {
        log.info("Persisting data.");
        final long start = System.currentTimeMillis();
        final Object commitMetadata = appenderator.persistAll(wrapCommitter(committer)).get();
        log.info("Persisted pending data in %,dms.", System.currentTimeMillis() - start);
        return commitMetadata;
      }
      catch (InterruptedException e) {
        throw e;
      }
      catch (Exception e) {
        throw new RuntimeException(e);
      }
    }