github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-03-21 15:45:01 +00:00
Code Issues Projects Releases Packages Wiki Activity

app/vmselect/promql: skip superflouos timestamps copying in count_values

Browse source
This commit is contained in:
Aliaksandr Valialkin 2019-06-11 00:43:45 +03:00
parent d2be567482
commit 8bb6bc986d
2 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
app/vmselect/promql/aggr.go
View file

@ -316,7 +316,7 @@ func aggrFuncCountValues(afa *aggrFuncArg) ([]*timeseries, error) {
var rvs []*timeseries var rvs []*timeseries
for _, v := range values { for _, v := range values {
var dst timeseries var dst timeseries
dst.CopyFrom(tss[0]) dst.CopyFromShallowTimestamps(tss[0])
dst.MetricName.RemoveTag(dstLabel) dst.MetricName.RemoveTag(dstLabel)
dst.MetricName.AddTag(dstLabel, strconv.FormatFloat(v, 'g', -1, 64)) dst.MetricName.AddTag(dstLabel, strconv.FormatFloat(v, 'g', -1, 64))
for i := range dst.Values { for i := range dst.Values {

6
app/vmselect/promql/timeseries.go
View file

@ -38,11 +38,13 @@ func (ts *timeseries) String() string {
return fmt.Sprintf("MetricName=%s, Values=%g, Timestamps=%d", &ts.MetricName, ts.Values, ts.Timestamps) return fmt.Sprintf("MetricName=%s, Values=%g, Timestamps=%d", &ts.MetricName, ts.Values, ts.Timestamps)
} }
func (ts *timeseries) CopyFrom(src *timeseries) { func (ts *timeseries) CopyFromShallowTimestamps(src *timeseries) {
ts.Reset() ts.Reset()
ts.MetricName.CopyFrom(&src.MetricName) ts.MetricName.CopyFrom(&src.MetricName)
ts.Values = append(ts.Values[:0], src.Values...) ts.Values = append(ts.Values[:0], src.Values...)
ts.Timestamps = append(ts.Timestamps[:0], src.Timestamps...) ts.Timestamps = src.Timestamps
ts.denyReuse = true
} }
func (ts *timeseries) CopyFromMetricNames(src *timeseries) { func (ts *timeseries) CopyFromMetricNames(src *timeseries) {