fix(bigtable): add gauge handling (#2830)

sushanb · web-flow · commit 915733bbaf21 · 2026-03-02T21:09:13.000-05:00
* fix(bigtable): handle gauge handling

* reformat
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/csm/exporter/Converter.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/csm/exporter/Converter.java
@@ -92,14 +92,14 @@ private Multimap<ProjectName, TimeSeries> convertMetricData(MetricData metricDat
     }
 
     ImmutableMultimap.Builder<ProjectName, TimeSeries> builder = ImmutableMultimap.builder();
-
+    MetricKind metricKind = convertMetricKind(metricData);
     for (PointData pd : metricData.getData().getPoints()) {
       ProjectName projectName =
           metricDef.getSchema().extractProjectName(pd.getAttributes(), envInfo, clientInfo);
 
       TimeSeries timeSeries =
           TimeSeries.newBuilder()
-              .setMetricKind(convertMetricKind(metricData))
+              .setMetricKind(metricKind)
               .setValueType(convertValueType(metricData.getType()))
               .setResource(
                   metricDef
@@ -110,18 +110,21 @@ private Multimap<ProjectName, TimeSeries> convertMetricData(MetricData metricDat
                       .setType(metricDef.getExternalName())
                       .putAllLabels(
                           metricDef.extractMetricLabels(pd.getAttributes(), envInfo, clientInfo)))
-              .addPoints(convertPointData(metricData.getType(), pd))
+              .addPoints(convertPointData(metricData.getType(), pd, metricKind))
               .build();
 
       builder.put(projectName, timeSeries);
     }
     return builder.build();
   }
 
-  private Point convertPointData(MetricDataType type, PointData pointData) {
+  private Point convertPointData(MetricDataType type, PointData pointData, MetricKind metricKind) {
+    long startNanos =
+        metricKind == GAUGE ? pointData.getEpochNanos() : pointData.getStartEpochNanos();
+
     TimeInterval timeInterval =
         TimeInterval.newBuilder()
-            .setStartTime(Timestamps.fromNanos(pointData.getStartEpochNanos()))
+            .setStartTime(Timestamps.fromNanos(startNanos))
             .setEndTime(Timestamps.fromNanos(pointData.getEpochNanos()))
             .build();
 
