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

Class MeasuredMutateRowsCallable

java.lang.Object

com.google.api.gax.rpc.UnaryCallable<BulkMutation,Void>

com.google.cloud.bigtable.data.v2.stub.metrics.MeasuredMutateRowsCallable

@InternalApi
public class MeasuredMutateRowsCallable
extends com.google.api.gax.rpc.UnaryCallable<BulkMutation,Void>

This callable will instrument MutateRows invocations using OpenCensus stats.

Recorded stats:

RpcMeasureConstants.BIGTABLE_OP_LATENCY

the total time it took the operation across all of its retry attempts to complete.

RpcMeasureConstants.BIGTABLE_MUTATE_ROWS_ENTRIES_PER_BATCH

the number of mutations sent per batch operation. Retry attempts might have few entries.

For internal use only.

Constructor Summary

Constructors

Constructor and Description
MeasuredMutateRowsCallable(com.google.api.gax.rpc.UnaryCallable<BulkMutation,Void> innerCallable, String methodName, io.opencensus.tags.Tagger tagger, io.opencensus.stats.StatsRecorder stats, com.google.api.core.ApiClock clock)

Method Summary

Modifier and Type	Method and Description
com.google.api.core.ApiFuture<Void>	futureCall(BulkMutation request, com.google.api.gax.rpc.ApiCallContext context)

Methods inherited from class com.google.api.gax.rpc.UnaryCallable

call, call, futureCall, withDefaultCallContext

Methods inherited from class java.lang.Object

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

Constructor Detail

MeasuredMutateRowsCallable

@InternalApi
public MeasuredMutateRowsCallable(@Nonnull
                                               com.google.api.gax.rpc.UnaryCallable<BulkMutation,Void> innerCallable,
                                               @Nonnull
                                               String methodName,
                                               @Nonnull
                                               io.opencensus.tags.Tagger tagger,
                                               @Nonnull
                                               io.opencensus.stats.StatsRecorder stats,
                                               @Nonnull
                                               com.google.api.core.ApiClock clock)

Method Detail

futureCall

public com.google.api.core.ApiFuture<Void> futureCall(BulkMutation request,
                                                      com.google.api.gax.rpc.ApiCallContext context)

Specified by:

futureCall in class com.google.api.gax.rpc.UnaryCallable<BulkMutation,Void>