com.google.cloud.bigtable.core
Interface IBulkMutation
-
- All Known Implementing Classes:
- BulkMutationGCJClient, BulkMutationWrapper
public interface IBulkMutation
Interface to support batching multipleRowMutation
request into a single grpc request.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method and Description com.google.api.core.ApiFuture<Void>
add(com.google.cloud.bigtable.data.v2.models.RowMutation rowMutation)
Adds aRowMutation
to the underlying IBulkMutation mechanism.void
flush()
Sends any outstandingRowMutation
and wait until all requests are complete.boolean
isFlushed()
void
sendUnsent()
Sends any outstandingRowMutation
s, present in the current batch.
-
-
-
Method Detail
-
add
com.google.api.core.ApiFuture<Void> add(com.google.cloud.bigtable.data.v2.models.RowMutation rowMutation)
Adds aRowMutation
to the underlying IBulkMutation mechanism.- Parameters:
rowMutation
- TheRowMutation
to add.- Returns:
- a
ApiFuture
of typeVoid
will be set when request is successful otherwise exception will be thrown.
-
sendUnsent
void sendUnsent()
Sends any outstandingRowMutation
s, present in the current batch.
-
flush
void flush() throws InterruptedException
Sends any outstandingRowMutation
and wait until all requests are complete.- Throws:
InterruptedException
-
isFlushed
boolean isFlushed()
- Returns:
- false if there is any outstanding
RowMutation
that still needs to be sent.
-
-