code: @SuppressWarnings("WeakerAccess")
    public ApiFuture<Void> awaitReplicationAsync(final String tableId) {
      // TODO(igorbernstein2): remove usage of trypesafe names
      com.google.bigtable.admin.v2.TableName tableName =
          com.google.bigtable.admin.v2.TableName.of(projectId, instanceId, tableId);
      return stub.awaitReplicationCallable().futureCall(tableName);
    }
docs: Returns a future that is resolved when replication has caught up to the point this method was
  called. This allows callers to make sure that their mutations have been replicated across all
  of their clusters.
  
  <p>Sample code:
  
  <pre>{@code
  ApiFuture<Void> replicationFuture = client.awaitReplicationAsync("my-table");
  
  ApiFutures.addCallback(
  replicationFuture,
  new ApiFutureCallback<Void>() {
  public void onSuccess(Table table) {
  System.out.println("All clusters are now consistent");
  }
  
  public void onFailure(Throwable t) {
  t.printStackTrace();
  }
  },
  MoreExecutors.directExecutor()
  );
  
  }</pre>