mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2024-11-21 14:44:00 +00:00
app/vmselect/promql: reduce the diff for f148cffc8a
This is a follow-up for c826f06366
This commit is contained in:
parent
27c4c5a530
commit
8a83c59956
1 changed files with 14 additions and 13 deletions
|
@ -572,22 +572,23 @@ func vmrangeBucketsToLE(tss []*timeseries) []*timeseries {
|
|||
})
|
||||
}
|
||||
xss = xssNew
|
||||
if len(xss) > 0 {
|
||||
for i := range xss[0].ts.Values {
|
||||
count := float64(0)
|
||||
for _, xs := range xss {
|
||||
ts := xs.ts
|
||||
v := ts.Values[i]
|
||||
if !math.IsNaN(v) && v > 0 {
|
||||
count += v
|
||||
}
|
||||
ts.Values[i] = count
|
||||
}
|
||||
}
|
||||
if len(xss) == 0 {
|
||||
continue
|
||||
}
|
||||
for i := range xss[0].ts.Values {
|
||||
count := float64(0)
|
||||
for _, xs := range xss {
|
||||
rvs = append(rvs, xs.ts)
|
||||
ts := xs.ts
|
||||
v := ts.Values[i]
|
||||
if !math.IsNaN(v) && v > 0 {
|
||||
count += v
|
||||
}
|
||||
ts.Values[i] = count
|
||||
}
|
||||
}
|
||||
for _, xs := range xss {
|
||||
rvs = append(rvs, xs.ts)
|
||||
}
|
||||
}
|
||||
return rvs
|
||||
}
|
||||
|
|
Loading…
Reference in a new issue