com.google.cloud.bigtable.core

Interface IBulkMutation

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

BulkMutationWrapper

@InternalApi(value="For internal usage only - please use BulkMutation instead")
public interface IBulkMutation
extends AutoCloseable

Interface to support batching multiple RowMutationEntry request into a single grpc * request.

For internal use only - public for technical reasons.

See BigtableSession.createBulkMutation(BigtableTableName) as a public alternative.

Method Summary

Modifier and Type	Method and Description
com.google.api.core.ApiFuture<Void>	add(com.google.cloud.bigtable.data.v2.models.RowMutationEntry rowMutation) Adds a RowMutationEntry to the underlying IBulkMutation mechanism.
void	close() Closes this bulk Mutation and prevents from mutating any more elements
void	flush() Sends any outstanding RowMutationEntry and blocks until all requests are complete.
void	sendUnsent() Sends any outstanding entry, present in the current batch but doesn't wait for response.

Method Detail

add

com.google.api.core.ApiFuture<Void> add(com.google.cloud.bigtable.data.v2.models.RowMutationEntry rowMutation)

Adds a RowMutationEntry to the underlying IBulkMutation mechanism.

Parameters:

rowMutation - The RowMutationEntry which holds row mutation details.

Returns:

a ApiFuture of type Void will be set when request is successful otherwise exception will be thrown.

sendUnsent

void sendUnsent()

Sends any outstanding entry, present in the current batch but doesn't wait for response.

flush

void flush()
    throws InterruptedException

Sends any outstanding RowMutationEntry and blocks until all requests are complete.

Throws:

InterruptedException

close

void close()
    throws IOException

Closes this bulk Mutation and prevents from mutating any more elements

Specified by:

close in interface AutoCloseable

Throws:

IOException