diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/metrics/BigtableTracerStreamingCallable.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/metrics/BigtableTracerStreamingCallable.java index 09bb906a89..6a902029eb 100644 --- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/metrics/BigtableTracerStreamingCallable.java +++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/metrics/BigtableTracerStreamingCallable.java @@ -58,8 +58,8 @@ public void call( final GrpcResponseMetadata responseMetadata = new GrpcResponseMetadata(); // tracer should always be an instance of bigtable tracer if (context.getTracer() instanceof BigtableTracer) { - HeaderTracerResponseObserver innerObserver = - new HeaderTracerResponseObserver<>( + BigtableTracerResponseObserver innerObserver = + new BigtableTracerResponseObserver<>( responseObserver, (BigtableTracer) context.getTracer(), responseMetadata); innerCallable.call(request, innerObserver, responseMetadata.addHandlers(context)); } else { @@ -67,13 +67,13 @@ public void call( } } - private class HeaderTracerResponseObserver implements ResponseObserver { + private class BigtableTracerResponseObserver implements ResponseObserver { private final BigtableTracer tracer; private final ResponseObserver outerObserver; private final GrpcResponseMetadata responseMetadata; - HeaderTracerResponseObserver( + BigtableTracerResponseObserver( ResponseObserver observer, BigtableTracer tracer, GrpcResponseMetadata metadata) { diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/metrics/BigtableTracerUnaryCallable.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/metrics/BigtableTracerUnaryCallable.java index fd2eb60f27..de53a0c94e 100644 --- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/metrics/BigtableTracerUnaryCallable.java +++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/metrics/BigtableTracerUnaryCallable.java @@ -53,8 +53,8 @@ public ApiFuture futureCall(RequestT request, ApiCallContext context) { if (context.getTracer() instanceof BigtableTracer) { final GrpcResponseMetadata responseMetadata = new GrpcResponseMetadata(); final ApiCallContext contextWithResponseMetadata = responseMetadata.addHandlers(context); - HeaderTracerUnaryCallback callback = - new HeaderTracerUnaryCallback((BigtableTracer) context.getTracer(), responseMetadata); + BigtableTracerUnaryCallback callback = + new BigtableTracerUnaryCallback((BigtableTracer) context.getTracer(), responseMetadata); ApiFuture future = innerCallable.futureCall(request, contextWithResponseMetadata); ApiFutures.addCallback(future, callback, MoreExecutors.directExecutor()); return future; @@ -63,12 +63,12 @@ public ApiFuture futureCall(RequestT request, ApiCallContext context) { } } - class HeaderTracerUnaryCallback implements ApiFutureCallback { + class BigtableTracerUnaryCallback implements ApiFutureCallback { private final BigtableTracer tracer; private final GrpcResponseMetadata responseMetadata; - HeaderTracerUnaryCallback(BigtableTracer tracer, GrpcResponseMetadata responseMetadata) { + BigtableTracerUnaryCallback(BigtableTracer tracer, GrpcResponseMetadata responseMetadata) { this.tracer = tracer; this.responseMetadata = responseMetadata; }