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-19 14:22:09 +02:00
parent 30a6aee52a
commit 38b9213a0c
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 20 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
lib/logstorage/pipe_extract.go
View file

@ -92,17 +92,32 @@ func (pep *pipeExtractProcessor) writeBlock(workerID uint, br *blockResult) {
} }
shard := &pep.shards[workerID] shard := &pep.shards[workerID]
c := br.getColumnByName(pep.pe.fromField)
values := c.getValues(br)
ef := shard.ef ef := shard.ef
rcs := shard.rcs rcs := shard.rcs
for _, v := range values {
c := br.getColumnByName(pep.pe.fromField)
if c.isConst {
v := c.valuesEncoded[0]
ef.apply(v) ef.apply(v)
for i, f := range ef.fields { for i, f := range ef.fields {
rcs[i].addValue(*f.value) fieldValue := *f.value
rc := &rcs[i]
for range br.timestamps {
rc.addValue(fieldValue)
} }
} }
} else {
values := c.getValues(br)
for i, v := range values {
if i == 0 || values[i-1] != v {
ef.apply(v)
}
for j, f := range ef.fields {
rcs[j].addValue(*f.value)
}
}
}
br.addResultColumns(rcs) br.addResultColumns(rcs)
pep.ppBase.writeBlock(workerID, br) pep.ppBase.writeBlock(workerID, br)