Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #5510 from bsideup/reduce_percentile_optimizations 

Optimize ReducePercentile method
pull/5633/head
Jason Wilder 2016-02-11 11:43:52 -07:00
parent 8d7a4a9acc eef0e41a7e
commit db9a14b65e
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
influxql/call_iterator.go
View File

@ -772,13 +772,14 @@ func newPercentileIterator(input Iterator, opt IteratorOptions, percentile float
// newFloatPercentileReduceSliceFunc returns the percentile value within a window.
func newFloatPercentileReduceSliceFunc(percentile float64) floatReduceSliceFunc {
return func(a []FloatPoint, opt *reduceOptions) []FloatPoint {
sort.Sort(floatPointsByValue(a))
i := int(math.Floor(float64(len(a))*percentile/100.0+0.5)) - 1
length := len(a)
i := int(math.Floor(float64(length)*percentile/100.0+0.5)) - 1
if i < 0 || i >= len(a) {
if i < 0 || i >= length {
return []FloatPoint{{Time: opt.startTime, Nil: true}}
}
sort.Sort(floatPointsByValue(a))
return []FloatPoint{{Time: opt.startTime, Value: a[i].Value}}
}
}
@ -786,13 +787,14 @@ func newFloatPercentileReduceSliceFunc(percentile float64) floatReduceSliceFunc
// newIntegerPercentileReduceSliceFunc returns the percentile value within a window.
func newIntegerPercentileReduceSliceFunc(percentile float64) integerReduceSliceFunc {
return func(a []IntegerPoint, opt *reduceOptions) []IntegerPoint {
sort.Sort(integerPointsByValue(a))
i := int(math.Floor(float64(len(a))*percentile/100.0+0.5)) - 1
length := len(a)
i := int(math.Floor(float64(length)*percentile/100.0+0.5)) - 1
if i < 0 || i >= len(a) {
if i < 0 || i >= length {
return nil
}
sort.Sort(integerPointsByValue(a))
return []IntegerPoint{{Time: opt.startTime, Value: a[i].Value}}
}
}