github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-11-21 14:44:00 +00:00
Code Issues Projects Releases Packages Wiki Activity

lib/logstorage: re-use per-shard fields across processed blocks in pipePackJSON and pipeUnroll

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-05-25 22:13:32 +02:00
parent 1882957585
commit 0b629ce5a5
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
2 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
lib/logstorage/pipe_pack_json.go
View file

@ -104,6 +104,7 @@ func (ppp *pipePackJSONProcessor) writeBlock(workerID uint, br *blockResult) {
v := bytesutil.ToUnsafeString(buf[bufLen:]) v := bytesutil.ToUnsafeString(buf[bufLen:])
shard.rc.addValue(v) shard.rc.addValue(v)
} }
shard.fields = fields
br.addResultColumn(&shard.rc) br.addResultColumn(&shard.rc)
ppp.ppNext.writeBlock(workerID, br) ppp.ppNext.writeBlock(workerID, br)

1
lib/logstorage/pipe_unroll.go
View file

@ -201,6 +201,7 @@ func (shard *pipeUnrollProcessorShard) writeUnrolledFields(br *blockResult, fiel
} }
shard.wctx.writeRow(rowIdx, fields) shard.wctx.writeRow(rowIdx, fields)
} }
shard.fields = fields
} }
func (pup *pipeUnrollProcessor) flush() error { func (pup *pipeUnrollProcessor) flush() error {