metricstarttimeprocessor: cache both int and double value for the sum datapoint (open-telemetry#42203)

<!--Ex. Fixing a bug - Describe the bug and how this fixes the issue.
Ex. Adding a feature - Explain what this achieves.-->
#### Description
Update the timeseries info structs so we also store the int values for
sums. And make sure we update and use this appropriately in the
strategies.

<!-- Issue number (e.g. #1234) or full URL to issue, if applicable. -->
#### Link to tracking issue
Fixes open-telemetry#42202

<!--Describe what testing was performed and which tests were added.-->
#### Testing
Added unit tests to the datapointstorage module, as well as to each
strategy.

<!--Describe the documentation added.-->
#### Documentation
N/A

<!--Please delete paragraphs that you did not use before submitting.-->

Signed-off-by: Ridwan Sharif <[email protected]>
Co-authored-by: David Ashpole <[email protected]>
Co-authored-by: Yang Song <[email protected]>

Author: 3 people

.chloggen/fix-adjust-int-sums.yaml

@@ -0,0 +1,27 @@
+# Use this changelog template to create an entry for release notes.
+
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: bug_fix
+
+# The name of the component, or a single word describing the area of concern, (e.g. filelogreceiver)
+component: processor/metricstarttime
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: Fixes bug where adjustment only relied on the DoubleValue and ignored the IntValue
+
+# Mandatory: One or more tracking issues related to the change. You can use the PR number here if no issue exists.
+issues: [42202]
+
+# (Optional) One or more lines of additional information to render under the primary note.
+# These lines will be padded with 2 spaces and then inserted directly into the document.
+# Use pipe (|) for multiline entries.
+subtext:
+
+# If your change doesn't affect end users or the exported elements of any package,
+# you should instead start your pull request title with [chore] or use the "Skip Changelog" label.
+# Optional: The change log or logs in which this entry should be included.
+# e.g. '[user]' or '[user, api]'
+# Include 'user' if the change is relevant to end users.
+# Include 'api' if there is a change to a library API.
+# Default: '[user]'
+change_logs: []

processor/metricstarttimeprocessor/internal/datapointstorage/timeseries_map.go

@@ -26,13 +26,15 @@ type TimeseriesInfo struct {
 }
 
 type NumberInfo struct {
-	StartTime     pcommon.Timestamp
-	PreviousValue float64
+	StartTime           pcommon.Timestamp
+	PreviousDoubleValue float64
+	PreviousIntValue    int64
 
 	// These are the optional reference values for strategies that need to cache
 	// additional data from the initial points.
 	// For example - storing the initial point for the subtract_initial_point strategy.
-	RefValue float64
+	RefDoubleValue float64
+	RefIntValue    int64
 }
 
 type HistogramInfo struct {
@@ -246,7 +248,7 @@ func (ref *TimeseriesInfo) IsResetSummary(s pmetric.SummaryDataPoint) bool {
 // whether the metric has been reset based on the values.  It is a reset if the
 // value has decreased.
 func (ref *TimeseriesInfo) IsResetSum(s pmetric.NumberDataPoint) bool {
-	return s.DoubleValue() < ref.Number.PreviousValue
+	return s.DoubleValue() < ref.Number.PreviousDoubleValue || s.IntValue() < ref.Number.PreviousIntValue
 }
 
 func newTimeseriesMap() *TimeseriesMap {

processor/metricstarttimeprocessor/internal/datapointstorage/timeseries_map_test.go

@@ -550,7 +550,7 @@ func TestTimeseriesInfo_IsResetSum(t *testing.T) {
 			name: "Double Value decreased",
 			setupTsi: func() *TimeseriesInfo {
 				tsi := &TimeseriesInfo{}
-				tsi.Number = NumberInfo{PreviousValue: 10}
+				tsi.Number = NumberInfo{PreviousDoubleValue: 10}
 				return tsi
 			},
 			setupS: func() pmetric.NumberDataPoint {
@@ -564,7 +564,7 @@ func TestTimeseriesInfo_IsResetSum(t *testing.T) {
 			name: "No Reset",
 			setupTsi: func() *TimeseriesInfo {
 				tsi := &TimeseriesInfo{}
-				tsi.Number = NumberInfo{PreviousValue: 10}
+				tsi.Number = NumberInfo{PreviousDoubleValue: 10}
 				return tsi
 			},
 			setupS: func() pmetric.NumberDataPoint {
@@ -574,6 +574,34 @@ func TestTimeseriesInfo_IsResetSum(t *testing.T) {
 			},
 			expectedReset: false,
 		},
+		{
+			name: "Double Value decreased - INT",
+			setupTsi: func() *TimeseriesInfo {
+				tsi := &TimeseriesInfo{}
+				tsi.Number = NumberInfo{PreviousIntValue: 10}
+				return tsi
+			},
+			setupS: func() pmetric.NumberDataPoint {
+				s := pmetric.NewNumberDataPoint()
+				s.SetIntValue(5)
+				return s
+			},
+			expectedReset: true,
+		},
+		{
+			name: "No Reset - INT",
+			setupTsi: func() *TimeseriesInfo {
+				tsi := &TimeseriesInfo{}
+				tsi.Number = NumberInfo{PreviousIntValue: 10}
+				return tsi
+			},
+			setupS: func() pmetric.NumberDataPoint {
+				s := pmetric.NewNumberDataPoint()
+				s.SetIntValue(15)
+				return s
+			},
+			expectedReset: false,
+		},
 	}
 
 	for _, tt := range tests {

processor/metricstarttimeprocessor/internal/starttimemetric/adjuster.go

@@ -88,7 +88,8 @@ func (a *Adjuster) AdjustMetrics(_ context.Context, metrics pmetric.Metrics) (pm
 						} else if refTsi.IsResetSum(dp) {
 							refTsi.Number.StartTime = pcommon.NewTimestampFromTime(dp.Timestamp().AsTime().Add(-1 * time.Millisecond))
 						}
-						refTsi.Number.PreviousValue = dp.DoubleValue()
+						refTsi.Number.PreviousDoubleValue = dp.DoubleValue()
+						refTsi.Number.PreviousIntValue = dp.IntValue()
 						dp.SetStartTimestamp(refTsi.Number.StartTime)
 					}
 

processor/metricstarttimeprocessor/internal/starttimemetric/adjuster_test.go

@@ -28,6 +28,7 @@ var (
 	percent0 = []float64{10, 50, 90}
 
 	sum1                  = "sum1"
+	sum2                  = "sum2"
 	gauge1                = "gauge1"
 	histogram1            = "histogram1"
 	summary1              = "summary1"
@@ -291,6 +292,7 @@ func TestMultiMetrics(t *testing.T) {
 				testhelper.SumMetric("example_process_start_time_seconds", testhelper.DoublePoint(nil, startTime, currentTime, matchBuilderStartTime)),
 				testhelper.GaugeMetric(gauge1, testhelper.DoublePoint(k1v1k2v2, t1, t1, 44)),
 				testhelper.SumMetric(sum1, testhelper.DoublePoint(k1v1k2v2, t1, t1, 44)),
+				testhelper.SumMetric(sum2, testhelper.IntPoint(k1v1k2v2, t1, t1, 44)),
 				testhelper.HistogramMetric(histogram1, testhelper.HistogramPoint(k1v1k2v2, t1, t1, bounds0, []uint64{4, 2, 3, 7})),
 				testhelper.ExponentialHistogramMetric(exponentialHistogram1, testhelper.ExponentialHistogramPoint(k1v1k2v2, t1, t1, 3, 1, 0, []uint64{}, -2, []uint64{4, 2, 3, 7})),
 				testhelper.SummaryMetric(summary1, testhelper.SummaryPoint(k1v1k2v2, t1, t1, 10, 40, percent0, []float64{1, 5, 8})),
@@ -299,6 +301,7 @@ func TestMultiMetrics(t *testing.T) {
 				testhelper.SumMetric("example_process_start_time_seconds", testhelper.DoublePoint(nil, matchedStartTimeStamp, currentTime, matchBuilderStartTime)),
 				testhelper.GaugeMetric(gauge1, testhelper.DoublePoint(k1v1k2v2, t1, t1, 44)),
 				testhelper.SumMetric(sum1, testhelper.DoublePoint(k1v1k2v2, matchedStartTimeStamp, t1, 44)),
+				testhelper.SumMetric(sum2, testhelper.IntPoint(k1v1k2v2, matchedStartTimeStamp, t1, 44)),
 				testhelper.HistogramMetric(histogram1, testhelper.HistogramPoint(k1v1k2v2, matchedStartTimeStamp, t1, bounds0, []uint64{4, 2, 3, 7})),
 				testhelper.ExponentialHistogramMetric(exponentialHistogram1, testhelper.ExponentialHistogramPoint(k1v1k2v2, matchedStartTimeStamp, t1, 3, 1, 0, []uint64{}, -2, []uint64{4, 2, 3, 7})),
 				testhelper.SummaryMetric(summary1, testhelper.SummaryPoint(k1v1k2v2, matchedStartTimeStamp, t1, 10, 40, percent0, []float64{1, 5, 8})),
@@ -310,6 +313,7 @@ func TestMultiMetrics(t *testing.T) {
 				testhelper.SumMetric("example_process_start_time_seconds", testhelper.DoublePoint(nil, startTime, currentTime, matchBuilderStartTime)),
 				testhelper.GaugeMetric(gauge1, testhelper.DoublePoint(k1v1k2v2, t2, t2, 66)),
 				testhelper.SumMetric(sum1, testhelper.DoublePoint(k1v1k2v2, t2, t2, 66)),
+				testhelper.SumMetric(sum2, testhelper.IntPoint(k1v1k2v2, t2, t2, 66)),
 				testhelper.HistogramMetric(histogram1, testhelper.HistogramPoint(k1v1k2v2, t2, t2, bounds0, []uint64{6, 3, 4, 8})),
 				testhelper.ExponentialHistogramMetric(exponentialHistogram1, testhelper.ExponentialHistogramPoint(k1v1k2v2, t2, t2, 3, 1, 0, []uint64{}, -2, []uint64{6, 2, 3, 7})),
 				testhelper.SummaryMetric(summary1, testhelper.SummaryPoint(k1v1k2v2, t2, t2, 15, 70, percent0, []float64{7, 44, 9})),
@@ -318,6 +322,7 @@ func TestMultiMetrics(t *testing.T) {
 				testhelper.SumMetric("example_process_start_time_seconds", testhelper.DoublePoint(nil, matchedStartTimeStamp, currentTime, matchBuilderStartTime)),
 				testhelper.GaugeMetric(gauge1, testhelper.DoublePoint(k1v1k2v2, t2, t2, 66)),
 				testhelper.SumMetric(sum1, testhelper.DoublePoint(k1v1k2v2, matchedStartTimeStamp, t2, 66)),
+				testhelper.SumMetric(sum2, testhelper.IntPoint(k1v1k2v2, matchedStartTimeStamp, t2, 66)),
 				testhelper.HistogramMetric(histogram1, testhelper.HistogramPoint(k1v1k2v2, matchedStartTimeStamp, t2, bounds0, []uint64{6, 3, 4, 8})),
 				testhelper.ExponentialHistogramMetric(exponentialHistogram1, testhelper.ExponentialHistogramPoint(k1v1k2v2, matchedStartTimeStamp, t2, 3, 1, 0, []uint64{}, -2, []uint64{6, 2, 3, 7})),
 				testhelper.SummaryMetric(summary1, testhelper.SummaryPoint(k1v1k2v2, matchedStartTimeStamp, t2, 15, 70, percent0, []float64{7, 44, 9})),
@@ -329,6 +334,7 @@ func TestMultiMetrics(t *testing.T) {
 				testhelper.SumMetric("example_process_start_time_seconds", testhelper.DoublePoint(nil, startTime, currentTime, matchBuilderStartTime)),
 				testhelper.GaugeMetric(gauge1, testhelper.DoublePoint(k1v1k2v2, t3, t3, 55)),
 				testhelper.SumMetric(sum1, testhelper.DoublePoint(k1v1k2v2, t3, t3, 55)),
+				testhelper.SumMetric(sum2, testhelper.IntPoint(k1v1k2v2, t3, t3, 55)),
 				testhelper.HistogramMetric(histogram1, testhelper.HistogramPoint(k1v1k2v2, t3, t3, bounds0, []uint64{5, 3, 2, 7})),
 				testhelper.ExponentialHistogramMetric(exponentialHistogram1, testhelper.ExponentialHistogramPoint(k1v1k2v2, t3, t3, 3, 1, 0, []uint64{}, -2, []uint64{5, 1, 2, 6})),
 				testhelper.SummaryMetric(summary1, testhelper.SummaryPoint(k1v1k2v2, t3, t3, 12, 66, percent0, []float64{3, 22, 5})),
@@ -337,6 +343,7 @@ func TestMultiMetrics(t *testing.T) {
 				testhelper.SumMetric("example_process_start_time_seconds", testhelper.DoublePoint(nil, matchedStartTimeStamp, currentTime, matchBuilderStartTime)),
 				testhelper.GaugeMetric(gauge1, testhelper.DoublePoint(k1v1k2v2, t3, t3, 55)),
 				testhelper.SumMetric(sum1, testhelper.DoublePoint(k1v1k2v2, t2, t3, 55)),
+				testhelper.SumMetric(sum2, testhelper.IntPoint(k1v1k2v2, t2, t3, 55)),
 				testhelper.HistogramMetric(histogram1, testhelper.HistogramPoint(k1v1k2v2, t2, t3, bounds0, []uint64{5, 3, 2, 7})),
 				testhelper.ExponentialHistogramMetric(exponentialHistogram1, testhelper.ExponentialHistogramPoint(k1v1k2v2, t2, t3, 3, 1, 0, []uint64{}, -2, []uint64{5, 1, 2, 6})),
 				testhelper.SummaryMetric(summary1, testhelper.SummaryPoint(k1v1k2v2, t2, t3, 12, 66, percent0, []float64{3, 22, 5})),
@@ -347,13 +354,15 @@ func TestMultiMetrics(t *testing.T) {
 			Metrics: testhelper.Metrics(
 				testhelper.SumMetric("example_process_start_time_seconds", testhelper.DoublePoint(nil, startTime, currentTime, matchBuilderStartTime)),
 				testhelper.SumMetric(sum1, testhelper.DoublePoint(k1v1k2v2, t4, t4, 72)),
+				testhelper.SumMetric(sum2, testhelper.IntPoint(k1v1k2v2, t4, t4, 72)),
 				testhelper.HistogramMetric(histogram1, testhelper.HistogramPoint(k1v1k2v2, t4, t4, bounds0, []uint64{7, 4, 2, 12})),
 				testhelper.ExponentialHistogramMetric(exponentialHistogram1, testhelper.ExponentialHistogramPoint(k1v1k2v2, t4, t4, 3, 1, 0, []uint64{}, -2, []uint64{6, 2, 3, 7})),
 				testhelper.SummaryMetric(summary1, testhelper.SummaryPoint(k1v1k2v2, t4, t4, 14, 96, percent0, []float64{9, 47, 8})),
 			),
 			Adjusted: testhelper.Metrics(
 				testhelper.SumMetric("example_process_start_time_seconds", testhelper.DoublePoint(nil, matchedStartTimeStamp, currentTime, matchBuilderStartTime)),
 				testhelper.SumMetric(sum1, testhelper.DoublePoint(k1v1k2v2, t2, t4, 72)),
+				testhelper.SumMetric(sum2, testhelper.IntPoint(k1v1k2v2, t2, t4, 72)),
 				testhelper.HistogramMetric(histogram1, testhelper.HistogramPoint(k1v1k2v2, t2, t4, bounds0, []uint64{7, 4, 2, 12})),
 				testhelper.ExponentialHistogramMetric(exponentialHistogram1, testhelper.ExponentialHistogramPoint(k1v1k2v2, t2, t4, 3, 1, 0, []uint64{}, -2, []uint64{6, 2, 3, 7})),
 				testhelper.SummaryMetric(summary1, testhelper.SummaryPoint(k1v1k2v2, t2, t4, 14, 96, percent0, []float64{9, 47, 8})),
@@ -364,13 +373,15 @@ func TestMultiMetrics(t *testing.T) {
 			Metrics: testhelper.Metrics(
 				testhelper.SumMetric("example_process_start_time_seconds", testhelper.DoublePoint(nil, startTime, currentTime, matchBuilderStartTime)),
 				testhelper.SumMetric(sum1, testhelper.DoublePoint(k1v1k2v2, t5, t5, 71)),
+				testhelper.SumMetric(sum2, testhelper.IntPoint(k1v1k2v2, t5, t5, 71)),
 				testhelper.HistogramMetric(histogram1, testhelper.HistogramPoint(k1v1k2v2, t5, t5, bounds0, []uint64{7, 4, 20, 11})),
 				testhelper.ExponentialHistogramMetric(exponentialHistogram1, testhelper.ExponentialHistogramPoint(k1v1k2v2, t5, t5, 3, 1, 0, []uint64{}, -2, []uint64{6, 2, 3, 6})),
 				testhelper.SummaryMetric(summary1, testhelper.SummaryPoint(k1v1k2v2, t5, t5, 14, 95, percent0, []float64{9, 47, 8})),
 			),
 			Adjusted: testhelper.Metrics(
 				testhelper.SumMetric("example_process_start_time_seconds", testhelper.DoublePoint(nil, matchedStartTimeStamp, currentTime, matchBuilderStartTime)),
 				testhelper.SumMetric(sum1, testhelper.DoublePoint(k1v1k2v2, t4, t5, 71)),
+				testhelper.SumMetric(sum2, testhelper.IntPoint(k1v1k2v2, t4, t5, 71)),
 				testhelper.HistogramMetric(histogram1, testhelper.HistogramPoint(k1v1k2v2, t4, t5, bounds0, []uint64{7, 4, 20, 11})),
 				testhelper.ExponentialHistogramMetric(exponentialHistogram1, testhelper.ExponentialHistogramPoint(k1v1k2v2, t4, t5, 3, 1, 0, []uint64{}, -2, []uint64{6, 2, 3, 6})),
 				testhelper.SummaryMetric(summary1, testhelper.SummaryPoint(k1v1k2v2, t4, t5, 14, 95, percent0, []float64{9, 47, 8})),

processor/metricstarttimeprocessor/internal/subtractinitial/adjuster.go

@@ -216,7 +216,13 @@ func adjustMetricSum(referenceValueTsm *datapointstorage.TimeseriesMap, metric p
 		refTsi, found := referenceValueTsm.Get(metric, currentSum.Attributes())
 		if !found {
 			// First time we see this point. Skip it and use as a reference point for the next points.
-			refTsi.Number = datapointstorage.NumberInfo{PreviousValue: currentSum.DoubleValue(), RefValue: currentSum.DoubleValue(), StartTime: currentSum.Timestamp()}
+			refTsi.Number = datapointstorage.NumberInfo{
+				PreviousDoubleValue: currentSum.DoubleValue(),
+				PreviousIntValue:    currentSum.IntValue(),
+				RefDoubleValue:      currentSum.DoubleValue(),
+				RefIntValue:         currentSum.IntValue(),
+				StartTime:           currentSum.Timestamp(),
+			}
 			return true
 		}
 
@@ -232,11 +238,20 @@ func adjustMetricSum(referenceValueTsm *datapointstorage.TimeseriesMap, metric p
 			currentSum.SetStartTimestamp(resetStartTimeStamp)
 
 			refTsi.Number.StartTime = resetStartTimeStamp
-			refTsi.Number.RefValue = 0
-			refTsi.Number.PreviousValue = currentSum.DoubleValue()
+			refTsi.Number.RefDoubleValue = 0
+			refTsi.Number.RefIntValue = 0
+			refTsi.Number.PreviousDoubleValue = currentSum.DoubleValue()
+			refTsi.Number.PreviousIntValue = currentSum.IntValue()
 		} else {
-			refTsi.Number.PreviousValue = currentSum.DoubleValue()
-			currentSum.SetDoubleValue(currentSum.DoubleValue() - refTsi.Number.RefValue)
+			refTsi.Number.PreviousDoubleValue = currentSum.DoubleValue()
+			refTsi.Number.PreviousIntValue = currentSum.IntValue()
+
+			// Update the currentSum appropriately based on the original value type.
+			if currentSum.ValueType() == pmetric.NumberDataPointValueTypeDouble {
+				currentSum.SetDoubleValue(currentSum.DoubleValue() - refTsi.Number.RefDoubleValue)
+			} else {
+				currentSum.SetIntValue(currentSum.IntValue() - refTsi.Number.RefIntValue)
+			}
 		}
 		return false
 	})

processor/metricstarttimeprocessor/internal/subtractinitial/adjuster_test.go

@@ -101,6 +101,37 @@ func TestSum(t *testing.T) {
 	testhelper.RunScript(t, NewAdjuster(componenttest.NewNopTelemetrySettings(), time.Minute), script)
 }
 
+func TestSumInt(t *testing.T) {
+	script := []*testhelper.MetricsAdjusterTest{
+		{
+			Description: "Sum: round 1 - initial instance, start time is established",
+			Metrics:     testhelper.Metrics(testhelper.SumMetric(sum1, testhelper.IntPoint(k1v1k2v2, t1, t1, 44))),
+			Adjusted:    testhelper.Metrics(testhelper.SumMetric(sum1)),
+		},
+		{
+			Description: "Sum: round 2 - instance adjusted based on round 1",
+			Metrics:     testhelper.Metrics(testhelper.SumMetric(sum1, testhelper.IntPoint(k1v1k2v2, t2, t2, 66))),
+			Adjusted:    testhelper.Metrics(testhelper.SumMetric(sum1, testhelper.IntPoint(k1v1k2v2, t1, t2, 22))),
+		},
+		{
+			Description: "Sum: round 3 - instance reset (value less than previous value), start time is reset",
+			Metrics:     testhelper.Metrics(testhelper.SumMetric(sum1, testhelper.IntPoint(k1v1k2v2, t3, t3, 55))),
+			Adjusted:    testhelper.Metrics(testhelper.SumMetric(sum1, testhelper.IntPoint(k1v1k2v2, t2, t3, 55))),
+		},
+		{
+			Description: "Sum: round 4 - instance adjusted based on round 3",
+			Metrics:     testhelper.Metrics(testhelper.SumMetric(sum1, testhelper.IntPoint(k1v1k2v2, t4, t4, 72))),
+			Adjusted:    testhelper.Metrics(testhelper.SumMetric(sum1, testhelper.IntPoint(k1v1k2v2, t2, t4, 72))),
+		},
+		{
+			Description: "Sum: round 5 - instance adjusted based on round 4 (value stayed the same))",
+			Metrics:     testhelper.Metrics(testhelper.SumMetric(sum1, testhelper.IntPoint(k1v1k2v2, t5, t5, 72))),
+			Adjusted:    testhelper.Metrics(testhelper.SumMetric(sum1, testhelper.IntPoint(k1v1k2v2, t2, t5, 72))),
+		},
+	}
+	testhelper.RunScript(t, NewAdjuster(componenttest.NewNopTelemetrySettings(), time.Minute), script)
+}
+
 func TestSumNoStartTimestamp(t *testing.T) {
 	script := []*testhelper.MetricsAdjusterTest{
 		{

processor/metricstarttimeprocessor/internal/testhelper/util.go

@@ -207,7 +207,7 @@ func ExponentialHistogramPointSimplified(attributes []*KV, startTimestamp, times
 	return hdp
 }
 
-func DoublePointRaw(attributes []*KV, startTimestamp, timestamp pcommon.Timestamp) pmetric.NumberDataPoint {
+func NumberPointRaw(attributes []*KV, startTimestamp, timestamp pcommon.Timestamp) pmetric.NumberDataPoint {
 	ndp := pmetric.NewNumberDataPoint()
 	ndp.SetStartTimestamp(startTimestamp)
 	ndp.SetTimestamp(timestamp)
@@ -220,13 +220,19 @@ func DoublePointRaw(attributes []*KV, startTimestamp, timestamp pcommon.Timestam
 }
 
 func DoublePoint(attributes []*KV, startTimestamp, timestamp pcommon.Timestamp, value float64) pmetric.NumberDataPoint {
-	ndp := DoublePointRaw(attributes, startTimestamp, timestamp)
+	ndp := NumberPointRaw(attributes, startTimestamp, timestamp)
 	ndp.SetDoubleValue(value)
 	return ndp
 }
 
+func IntPoint(attributes []*KV, startTimestamp, timestamp pcommon.Timestamp, value int64) pmetric.NumberDataPoint {
+	ndp := NumberPointRaw(attributes, startTimestamp, timestamp)
+	ndp.SetIntValue(value)
+	return ndp
+}
+
 func DoublePointNoValue(attributes []*KV, startTimestamp, timestamp pcommon.Timestamp) pmetric.NumberDataPoint {
-	ndp := DoublePointRaw(attributes, startTimestamp, timestamp)
+	ndp := NumberPointRaw(attributes, startTimestamp, timestamp)
 	ndp.SetFlags(pmetric.DefaultDataPointFlags.WithNoRecordedValue(true))
 	return ndp
 }

processor/metricstarttimeprocessor/internal/truereset/adjuster.go

@@ -186,7 +186,11 @@ func (*Adjuster) adjustMetricSum(tsm *datapointstorage.TimeseriesMap, current pm
 		refTsi, found := tsm.Get(current, currentSum.Attributes())
 		if !found {
 			// initialize everything.
-			refTsi.Number = datapointstorage.NumberInfo{PreviousValue: currentSum.DoubleValue(), StartTime: currentSum.Timestamp()}
+			refTsi.Number = datapointstorage.NumberInfo{
+				PreviousDoubleValue: currentSum.DoubleValue(),
+				PreviousIntValue:    currentSum.IntValue(),
+				StartTime:           currentSum.Timestamp(),
+			}
 
 			// For the first point, set the start time as the point timestamp.
 			currentSum.SetStartTimestamp(currentSum.Timestamp())
@@ -206,7 +210,8 @@ func (*Adjuster) adjustMetricSum(tsm *datapointstorage.TimeseriesMap, current pm
 		}
 
 		// Update only previous values.
-		refTsi.Number.PreviousValue = currentSum.DoubleValue()
+		refTsi.Number.PreviousDoubleValue = currentSum.DoubleValue()
+		refTsi.Number.PreviousIntValue = currentSum.IntValue()
 		currentSum.SetStartTimestamp(refTsi.Number.StartTime)
 	}
 }