Method Combine

pkg/traceql/engine_metrics.go:1628–1664

(in []*tempopb.TimeSeries)

}

func (b *SimpleAggregator) Combine(in []*tempopb.TimeSeries) {
	nan := math.Float64frombits(normalNaN)

	for _, ts := range in {
		// Convert proto labels to traceql labels
		labels, _ := convertProtoLabelsToTraceQL(ts.Labels, false)
		key := labels.MapKey()

		existing, ok := b.ss[key]
		if !ok {

			existing = TimeSeries{
				Labels:    labels,
				Values:    make([]float64, b.intervalMapper.IntervalCount()),
				Exemplars: make([]Exemplar, 0, len(ts.Exemplars)),
			}
			if b.initWithNaN {
				for i := range existing.Values {
					existing.Values[i] = nan
				}
			}

			b.ss[key] = existing
		}

		for _, sample := range ts.Samples {
			j := b.intervalMapper.IntervalMs(sample.TimestampMs)
			if j >= 0 && j < len(existing.Values) {
				existing.Values[j] = b.aggregationFunc(existing.Values[j], sample.Value)
			}
		}

		b.aggregateExemplars(ts, &existing)

		b.ss[key] = existing
	}
}

func (b *SimpleAggregator) aggregateExemplars(ts *tempopb.TimeSeries, existing *TimeSeries) {
	for _, exemplar := range ts.Exemplars {