update

Author: mutianf

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/metrics/BigtableCloudMonitoringExporter.java

@@ -16,6 +16,7 @@
 package com.google.cloud.bigtable.data.v2.stub.metrics;
 
 import com.google.api.MonitoredResource;
+import com.google.api.core.ApiFuture;
 import com.google.api.gax.core.FixedCredentialsProvider;
 import com.google.auth.Credentials;
 import com.google.cloud.monitoring.v3.MetricServiceClient;
@@ -25,6 +26,7 @@
 import com.google.monitoring.v3.CreateTimeSeriesRequest;
 import com.google.monitoring.v3.ProjectName;
 import com.google.monitoring.v3.TimeSeries;
+import com.google.protobuf.Empty;
 import io.opentelemetry.sdk.common.CompletableResultCode;
 import io.opentelemetry.sdk.metrics.InstrumentType;
 import io.opentelemetry.sdk.metrics.data.AggregationTemporality;
@@ -47,6 +49,7 @@ final class BigtableCloudMonitoringExporter implements MetricExporter {
   private final String projectId;
   private final String taskId;
   private final MonitoredResource monitoredResource;
+  private boolean isShutdown = false;
 
   private static final String RESOURCE_TYPE = "bigtable_client_raw";
 
@@ -78,6 +81,9 @@ static BigtableCloudMonitoringExporter create(String projectId, Credentials cred
 
   @Override
   public CompletableResultCode export(Collection<MetricData> collection) {
+    if (isShutdown) {
+      return CompletableResultCode.ofFailure();
+    }
     Preconditions.checkArgument(
         collection.stream()
             .flatMap(metricData -> metricData.getData().getPoints().stream())
@@ -102,7 +108,7 @@ public CompletableResultCode export(Collection<MetricData> collection) {
               .addAllTimeSeries(timeSeries)
               .build();
 
-      this.client.createServiceTimeSeries(request);
+      this.client.createServiceTimeSeriesCallable().futureCall(request);
     }
 
     return CompletableResultCode.ofSuccess();
@@ -116,6 +122,7 @@ public CompletableResultCode flush() {
   @Override
   public CompletableResultCode shutdown() {
     client.shutdown();
+    isShutdown = true;
     return CompletableResultCode.ofSuccess();
   }