com.google.cloud.bigtable.data.v2.stub.mutaterows

Class MutateRowsBatchingDescriptor

java.lang.Object

com.google.cloud.bigtable.data.v2.stub.mutaterows.MutateRowsBatchingDescriptor

All Implemented Interfaces:

BatchingDescriptor<com.google.bigtable.v2.MutateRowsRequest,Void>

@InternalApi
public class MutateRowsBatchingDescriptor
extends Object
implements BatchingDescriptor<com.google.bigtable.v2.MutateRowsRequest,Void>

A custom implementation of a BatchingDescriptor to split individual results in a MutateRowsException. Each individual result will be matched with its issuer.

This class is considered an internal implementation detail and not meant to be used by applications directly.

Constructor Summary

Constructors

Constructor and Description
MutateRowsBatchingDescriptor()

Method Summary

Modifier and Type	Method and Description
long	countBytes(com.google.bigtable.v2.MutateRowsRequest request)
long	countElements(com.google.bigtable.v2.MutateRowsRequest request)
PartitionKey	getBatchPartitionKey(com.google.bigtable.v2.MutateRowsRequest request) Return the target table name.
RequestBuilder<com.google.bigtable.v2.MutateRowsRequest>	getRequestBuilder()
void	splitException(Throwable throwable, Collection<? extends BatchedRequestIssuer<Void>> batch)
void	splitResponse(Void batchResponse, Collection<? extends BatchedRequestIssuer<Void>> batch)

Methods inherited from class java.lang.Object

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

Constructor Detail

MutateRowsBatchingDescriptor

public MutateRowsBatchingDescriptor()

Method Detail

getBatchPartitionKey

public PartitionKey getBatchPartitionKey(com.google.bigtable.v2.MutateRowsRequest request)

Return the target table name. This will be used to combine batcheable requests

Specified by:

getBatchPartitionKey in interface BatchingDescriptor<com.google.bigtable.v2.MutateRowsRequest,Void>

getRequestBuilder

public RequestBuilder<com.google.bigtable.v2.MutateRowsRequest> getRequestBuilder()

Specified by:

getRequestBuilder in interface BatchingDescriptor<com.google.bigtable.v2.MutateRowsRequest,Void>

splitResponse

public void splitResponse(Void batchResponse,
                          Collection<? extends BatchedRequestIssuer<Void>> batch)

Specified by:

splitResponse in interface BatchingDescriptor<com.google.bigtable.v2.MutateRowsRequest,Void>

splitException

public void splitException(Throwable throwable,
                           Collection<? extends BatchedRequestIssuer<Void>> batch)

Specified by:

splitException in interface BatchingDescriptor<com.google.bigtable.v2.MutateRowsRequest,Void>

countElements

public long countElements(com.google.bigtable.v2.MutateRowsRequest request)

Specified by:

countElements in interface BatchingDescriptor<com.google.bigtable.v2.MutateRowsRequest,Void>

countBytes

public long countBytes(com.google.bigtable.v2.MutateRowsRequest request)

Specified by:

countBytes in interface BatchingDescriptor<com.google.bigtable.v2.MutateRowsRequest,Void>