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-06 23:03:42 +02:00
parent ba20bb08d3
commit adcdb92b1e
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
3 changed files with 14 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lib/logstorage/block_result.go
View file

@ -1560,8 +1560,7 @@ type resultColumn struct {
values []string
}
func (rc *resultColumn) reset() {
rc.name = ""
func (rc *resultColumn) resetKeepName() {
rc.buf = rc.buf[:0]
clear(rc.values)

21
lib/logstorage/pipe_sort.go
View file

@ -466,14 +466,14 @@ type pipeSortWriteContext struct {
func (wctx *pipeSortWriteContext) writeRow(shard *pipeSortProcessorShard, rowIdx uint) {
rr := shard.rowRefs[rowIdx]
block := &shard.blocks[rr.blockIdx]
b := &shard.blocks[rr.blockIdx]
byFields := shard.ps.byFields
rcs := wctx.rcs
areEqualColumns := len(rcs) == len(byFields)+len(block.otherColumns)
areEqualColumns := len(rcs) == len(byFields)+len(b.otherColumns)
if areEqualColumns {
for i, c := range block.otherColumns {
for i, c := range b.otherColumns {
if rcs[len(byFields)+i].name != c.name {
areEqualColumns = false
break
@ -490,7 +490,7 @@ func (wctx *pipeSortWriteContext) writeRow(shard *pipeSortProcessorShard, rowIdx
name: bf.name,
})
}
for _, c := range block.otherColumns {
for _, c := range b.otherColumns {
rcs = append(rcs, resultColumn{
name: c.name,
})
@ -498,13 +498,16 @@ func (wctx *pipeSortWriteContext) writeRow(shard *pipeSortProcessorShard, rowIdx
wctx.rcs = rcs
}
for i, c := range block.byColumns {
v := c.values[rr.rowIdx]
byColumns := b.byColumns
for i := range byFields {
v := byColumns[i].values[rr.rowIdx]
rcs[i].addValue(v)
wctx.valuesLen += len(v)
}
for i, c := range block.otherColumns {
v := c.values[rr.rowIdx]
otherColumns := b.otherColumns
for i := range otherColumns {
v := otherColumns[i].values[rr.rowIdx]
rcs[len(byFields)+i].addValue(v)
wctx.valuesLen += len(v)
}
@ -529,7 +532,7 @@ func (wctx *pipeSortWriteContext) flush() {
wctx.psp.ppBase.writeBlock(0, br)
br.reset()
for i := range rcs {
rcs[i].reset()
rcs[i].resetKeepName()
}
}

2
lib/logstorage/pipe_stats.go
View file

@ -411,7 +411,7 @@ func (psp *pipeStatsProcessor) flush() error {
psp.ppBase.writeBlock(0, &br)
br.reset()
for i := range rcs {
rcs[i].reset()
rcs[i].resetKeepName()
}
valuesLen = 0
}