Skip to content

Commit c59bfb6

Browse files
committed
add it
1 parent fa43a91 commit c59bfb6

File tree

1 file changed

+10
-5
lines changed

1 file changed

+10
-5
lines changed

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

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -303,9 +303,10 @@ private static TimeSeries convertPointToBigtableTimeSeries(
303303

304304
private static Optional<TimeSeries> createInternalMetricsTimeSeries(
305305
MetricData metricData, PointData pointData, MonitoredResource applicationResource) {
306+
MetricKind kind = convertMetricKind(metricData);
306307
TimeSeries.Builder builder =
307308
TimeSeries.newBuilder()
308-
.setMetricKind(convertMetricKind(metricData))
309+
.setMetricKind(kind)
309310
.setValueType(convertValueType(metricData.getType()))
310311
.setResource(applicationResource);
311312

@@ -327,11 +328,15 @@ private static Optional<TimeSeries> createInternalMetricsTimeSeries(
327328

328329
builder.setMetric(metricBuilder.build());
329330

331+
Timestamp endTimestamp = Timestamps.fromNanos(pointData.getEpochNanos());
332+
Timestamp startTimestamp;
333+
if (kind == GAUGE) {
334+
startTimestamp = endTimestamp;
335+
} else {
336+
startTimestamp = Timestamps.fromNanos(pointData.getStartEpochNanos());
337+
}
330338
TimeInterval timeInterval =
331-
TimeInterval.newBuilder()
332-
.setStartTime(Timestamps.fromNanos(pointData.getStartEpochNanos()))
333-
.setEndTime(Timestamps.fromNanos(pointData.getEpochNanos()))
334-
.build();
339+
TimeInterval.newBuilder().setStartTime(startTimestamp).setEndTime(endTimestamp).build();
335340

336341
builder.addPoints(createPoint(metricData.getType(), pointData, timeInterval));
337342
return Optional.of(builder.build());

0 commit comments

Comments
 (0)