github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-31 15:06:26 +00:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-05-21 00:06:58 +02:00
parent 5e61b40fef
commit d75b0df747
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lib/logstorage/pipe_topk.go
View file

@ -258,7 +258,8 @@ func (shard *pipeTopkProcessorShard) addRow(br *blockResult, byColumns []string,
r.timestamp = timestamp r.timestamp = timestamp
rows := shard.rows rows := shard.rows
if len(rows) > 0 && !topkLess(shard.ps, r, rows[0]) { maxRows := shard.ps.offset + shard.ps.limit
if uint64(len(rows)) >= maxRows && !topkLess(shard.ps, r, rows[0]) {
// Fast path - nothing to add. // Fast path - nothing to add.
return return
} }
@ -282,7 +283,7 @@ func (shard *pipeTopkProcessorShard) addRow(br *blockResult, byColumns []string,
shard.stateSizeBudget -= r.sizeBytes() shard.stateSizeBudget -= r.sizeBytes()
// Push r to shard.rows. // Push r to shard.rows.
if uint64(len(rows)) < shard.ps.offset+shard.ps.limit { if uint64(len(rows)) < maxRows {
heap.Push(shard, r) heap.Push(shard, r)
shard.stateSizeBudget -= int(unsafe.Sizeof(r)) shard.stateSizeBudget -= int(unsafe.Sizeof(r))
} else { } else {