@ 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 ) ; }
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 .