com.google.cloud.bigtable.grpc.async

Class BulkMutation

java.lang.Object

com.google.cloud.bigtable.grpc.async.BulkMutation

@InternalExtensionOnly
public class BulkMutation
extends Object

This class combines a collection of MutateRowRequests into a single MutateRowsRequest. This class is not thread safe, and requires calling classes to make it thread safe.

Field Summary

Fields

Modifier and Type	Field and Description
static long	MAX_NUMBER_OF_MUTATIONS For internal use only - public for technical reasons.
static long	MAX_RPC_WAIT_TIME_NANOS For internal use only - public for technical reasons.

Constructor Summary

Constructors

Constructor and Description
BulkMutation(BigtableTableName tableName, BigtableDataClient client, ScheduledExecutorService retryExecutorService, BulkOptions bulkOptions) For internal use only - public for technical reasons.

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<com.google.bigtable.v2.MutateRowResponse>	add(com.google.bigtable.v2.MutateRowRequest request)
com.google.common.util.concurrent.ListenableFuture<com.google.bigtable.v2.MutateRowResponse>	add(com.google.bigtable.v2.MutateRowsRequest.Entry entry) Adds a MutateRowsRequest.Entry to the MutateRowsRequest.Builder.
void	flush() Send any outstanding MutateRowRequests and wait until all requests are complete.
boolean	isFlushed()
void	sendUnsent()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAX_RPC_WAIT_TIME_NANOS

@InternalApi(value="For internal usage only")
public static final long MAX_RPC_WAIT_TIME_NANOS

For internal use only - public for technical reasons.

MAX_NUMBER_OF_MUTATIONS

@InternalApi(value="For internal usage only")
public static final long MAX_NUMBER_OF_MUTATIONS

For internal use only - public for technical reasons.

See Also:

Constant Field Values

Constructor Detail

BulkMutation

@InternalApi(value="For internal usage only")
public BulkMutation(BigtableTableName tableName,
                                                                  BigtableDataClient client,
                                                                  ScheduledExecutorService retryExecutorService,
                                                                  BulkOptions bulkOptions)

For internal use only - public for technical reasons.

Method Detail

add

public com.google.common.util.concurrent.ListenableFuture<com.google.bigtable.v2.MutateRowResponse> add(com.google.bigtable.v2.MutateRowRequest request)

add

public com.google.common.util.concurrent.ListenableFuture<com.google.bigtable.v2.MutateRowResponse> add(com.google.bigtable.v2.MutateRowsRequest.Entry entry)

Adds a MutateRowsRequest.Entry to the MutateRowsRequest.Builder.

Parameters:

entry - The MutateRowsRequest.Entry to add

Returns:

a SettableFuture that will be populated when the MutateRowsResponse returns from the server. See BulkMutation.Batch.addCallback(ListenableFuture) for more information about how the SettableFuture is set.

flush

public void flush()
           throws InterruptedException

Send any outstanding MutateRowRequests and wait until all requests are complete.

Throws:

InterruptedException

sendUnsent

public void sendUnsent()

isFlushed

public boolean isFlushed()

Returns:

false if there are any outstanding MutateRowRequest that still need to be sent.