com.google.cloud.bigtable.data.v2.internal

Class DummyBatchingDescriptor<RequestT,ResponseT>

java.lang.Object

com.google.cloud.bigtable.data.v2.internal.DummyBatchingDescriptor<RequestT,ResponseT>

All Implemented Interfaces:

BatchingDescriptor<RequestT,ResponseT>

@InternalApi
public class DummyBatchingDescriptor<RequestT,ResponseT>
extends Object
implements BatchingDescriptor<RequestT,ResponseT>

This is necessary workaround for EnhancedBigtableStub.bulkMutateRowsCallable(). The settings are exposed to the user using the RowMutation wrapper, but the actual descriptor works on the underlying MutateRowsRequests. This class is used as a placeholder for the settings and is replaced with the actual implementation of MutateRowsBatchingDescriptor when constructing the callable chain.

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

Constructor Summary

Constructors

Constructor and Description
DummyBatchingDescriptor()

Method Summary

Modifier and Type	Method and Description
long	countBytes(RequestT request)
long	countElements(RequestT request)
PartitionKey	getBatchPartitionKey(RequestT request)
RequestBuilder<RequestT>	getRequestBuilder()
void	splitException(Throwable throwable, Collection<? extends BatchedRequestIssuer<ResponseT>> collection)
void	splitResponse(ResponseT response, Collection<? extends BatchedRequestIssuer<ResponseT>> collection)

Methods inherited from class java.lang.Object

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

Constructor Detail

DummyBatchingDescriptor

public DummyBatchingDescriptor()

Method Detail

getBatchPartitionKey

public PartitionKey getBatchPartitionKey(RequestT request)

Specified by:

getBatchPartitionKey in interface BatchingDescriptor<RequestT,ResponseT>

getRequestBuilder

public RequestBuilder<RequestT> getRequestBuilder()

Specified by:

getRequestBuilder in interface BatchingDescriptor<RequestT,ResponseT>

splitResponse

public void splitResponse(ResponseT response,
                          Collection<? extends BatchedRequestIssuer<ResponseT>> collection)

Specified by:

splitResponse in interface BatchingDescriptor<RequestT,ResponseT>

splitException

public void splitException(Throwable throwable,
                           Collection<? extends BatchedRequestIssuer<ResponseT>> collection)

Specified by:

splitException in interface BatchingDescriptor<RequestT,ResponseT>

countElements

public long countElements(RequestT request)

Specified by:

countElements in interface BatchingDescriptor<RequestT,ResponseT>

countBytes

public long countBytes(RequestT request)

Specified by:

countBytes in interface BatchingDescriptor<RequestT,ResponseT>