mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2024-12-24 03:06:48 +01:00
103 lines
2.1 KiB
Go
103 lines
2.1 KiB
Go
package logstorage
|
|
|
|
import (
|
|
"math"
|
|
"slices"
|
|
"strconv"
|
|
"unsafe"
|
|
)
|
|
|
|
type statsMin struct {
|
|
fields []string
|
|
containsStar bool
|
|
}
|
|
|
|
func (sm *statsMin) String() string {
|
|
return "min(" + fieldNamesString(sm.fields) + ")"
|
|
}
|
|
|
|
func (sm *statsMin) neededFields() []string {
|
|
return sm.fields
|
|
}
|
|
|
|
func (sm *statsMin) newStatsProcessor() (statsProcessor, int) {
|
|
smp := &statsMinProcessor{
|
|
sm: sm,
|
|
min: nan,
|
|
}
|
|
return smp, int(unsafe.Sizeof(*smp))
|
|
}
|
|
|
|
type statsMinProcessor struct {
|
|
sm *statsMin
|
|
|
|
min float64
|
|
}
|
|
|
|
func (smp *statsMinProcessor) updateStatsForAllRows(br *blockResult) int {
|
|
if smp.sm.containsStar {
|
|
// Find the minimum value across all the columns
|
|
for _, c := range br.getColumns() {
|
|
f := c.getMinValue(br)
|
|
if f < smp.min || math.IsNaN(smp.min) {
|
|
smp.min = f
|
|
}
|
|
}
|
|
} else {
|
|
// Find the minimum value across the requested columns
|
|
for _, field := range smp.sm.fields {
|
|
c := br.getColumnByName(field)
|
|
f := c.getMinValue(br)
|
|
if f < smp.min || math.IsNaN(smp.min) {
|
|
smp.min = f
|
|
}
|
|
}
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (smp *statsMinProcessor) updateStatsForRow(br *blockResult, rowIdx int) int {
|
|
if smp.sm.containsStar {
|
|
// Find the minimum value across all the fields for the given row
|
|
for _, c := range br.getColumns() {
|
|
f := c.getFloatValueAtRow(rowIdx)
|
|
if f < smp.min || math.IsNaN(smp.min) {
|
|
smp.min = f
|
|
}
|
|
}
|
|
} else {
|
|
// Find the minimum value across the requested fields for the given row
|
|
for _, field := range smp.sm.fields {
|
|
c := br.getColumnByName(field)
|
|
f := c.getFloatValueAtRow(rowIdx)
|
|
if f < smp.min || math.IsNaN(smp.min) {
|
|
smp.min = f
|
|
}
|
|
}
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (smp *statsMinProcessor) mergeState(sfp statsProcessor) {
|
|
src := sfp.(*statsMinProcessor)
|
|
if src.min < smp.min {
|
|
smp.min = src.min
|
|
}
|
|
}
|
|
|
|
func (smp *statsMinProcessor) finalizeStats() string {
|
|
return strconv.FormatFloat(smp.min, 'g', -1, 64)
|
|
}
|
|
|
|
func parseStatsMin(lex *lexer) (*statsMin, error) {
|
|
fields, err := parseFieldNamesForStatsFunc(lex, "min")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
sm := &statsMin{
|
|
fields: fields,
|
|
containsStar: slices.Contains(fields, "*"),
|
|
}
|
|
return sm, nil
|
|
}
|