com.google.cloud.bigtable.data.v2.models

Class BulkMutationBatcher

java.lang.Object

com.google.cloud.bigtable.data.v2.models.BulkMutationBatcher

All Implemented Interfaces:

AutoCloseable

@BetaApi(value="This surface is likely to change as the batching surface evolves.")
public final class BulkMutationBatcher
extends Object
implements AutoCloseable

Tracker for outstanding bulk mutations. Allows for the caller to wait for all of the outstanding mutations to complete.

See Also:

for example usage.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BulkMutationBatcher.BulkMutationFailure Thrown when at least one mutation failed in a batch.

Constructor Summary

Constructors

Constructor and Description
BulkMutationBatcher(UnaryCallable<RowMutation,Void> callable)

Method Summary

Modifier and Type	Method and Description
ApiFuture<Void>	add(RowMutation rowMutation) Queues the mutation to be batched and sent.
void	close() Waits up to 10 minutes for all of the outstanding mutations to be resolved.
void	close(org.threeten.bp.Duration duration) Prevents further mutations and waits for all outstanding mutations to complete.

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkMutationBatcher

@InternalApi
public BulkMutationBatcher(UnaryCallable<RowMutation,Void> callable)

Method Detail

close

public void close()
           throws InterruptedException,
                  TimeoutException

Waits up to 10 minutes for all of the outstanding mutations to be resolved.

Specified by:

close in interface AutoCloseable

Throws:

InterruptedException

TimeoutException

See Also:

for more infortmation.

close

public void close(org.threeten.bp.Duration duration)
           throws InterruptedException,
                  TimeoutException

Prevents further mutations and waits for all outstanding mutations to complete.

Throws:

BulkMutationBatcher.BulkMutationFailure - If any mutations failed.

InterruptedException - If interrupted.

TimeoutException - If the outstanding requests don't finish in time.

add

public ApiFuture<Void> add(RowMutation rowMutation)

Queues the mutation to be batched and sent. Please note that the order of mutations is not guaranteed.

Throws:

IllegalStateException - If this instance has been closed.