@Override
  public CompletableFuture<Void> putAllAsync(List<Entry<K, V>> entries, Object ... args) {
    return doWrite(() -> table.putAllAsync(entries, args));
  }
A composable asynchronous retriable table implementation that supports features
defined in {@link TableRetryPolicy}.

@param <K> the type of the key in this table
@param <V> the type of the value in this table
@param <U> the type of the update applied to records in this table
samza-core/src/main/java/org/apache/samza/table/retry/AsyncRetriableTable.java