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

Class MeasuredReadRowsCallable<RowT>

java.lang.Object

com.google.api.gax.rpc.ServerStreamingCallable<Query,RowT>

com.google.cloud.bigtable.data.v2.stub.metrics.MeasuredReadRowsCallable<RowT>

@InternalApi
public class MeasuredReadRowsCallable<RowT>
extends com.google.api.gax.rpc.ServerStreamingCallable<Query,RowT>

This callable will instrument ReadRows 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_ROWS_READ_PER_OP

the number of rows received across all of the retries for each invocation.

RpcMeasureConstants.BIGTABLE_READ_ROWS_FIRST_ROW_LATENCY

the amount of time it took the caller to receive the first row.

For internal use only.

Constructor Summary

Constructors

Constructor and Description
MeasuredReadRowsCallable(com.google.api.gax.rpc.ServerStreamingCallable<Query,RowT> 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
void	call(Query request, com.google.api.gax.rpc.ResponseObserver<RowT> outerObserver, com.google.api.gax.rpc.ApiCallContext context)

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

all, blockingServerStreamingCall, blockingServerStreamingCall, call, call, call, first, serverStreamingCall, serverStreamingCall, withDefaultCallContext

Methods inherited from class java.lang.Object

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

Constructor Detail

MeasuredReadRowsCallable

public MeasuredReadRowsCallable(@Nonnull
                                com.google.api.gax.rpc.ServerStreamingCallable<Query,RowT> 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

call

public void call(Query request,
                 com.google.api.gax.rpc.ResponseObserver<RowT> outerObserver,
                 com.google.api.gax.rpc.ApiCallContext context)

Specified by:

call in class com.google.api.gax.rpc.ServerStreamingCallable<Query,RowT>