Mirrors/miller
1
0
Fork 0
mirror of https://github.com/johnkerl/miller.git synced 2026-01-23 02:14:13 +00:00
Code Issues Projects Releases Wiki Activity

iterating

Browse source
This commit is contained in:
John Kerl 2025-03-08 20:41:36 -05:00
parent b08bb1b3dd
commit 6da45fef72
1 changed files with 6 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

17
pkg/transformers/bar.go
View file

@ -194,7 +194,7 @@ func NewTransformerBar(
if doAuto {
tr.recordTransformerFunc = tr.processAuto
tr.recordsForAutoMode = list.New()
tr.recordsForAutoMode = make([]*types.RecordAndContext, 10) // XXX records per batch
} else {
tr.recordTransformerFunc = tr.processNoAuto
tr.recordsForAutoMode = nil
@ -258,7 +258,7 @@ func (tr *TransformerBar) processAuto(
outputDownstreamDoneChannel chan<- bool,
) {
if !inrecAndContext.EndOfStream {
tr.recordsForAutoMode.PushBack(inrecAndContext.Copy())
tr.recordsForAutoMode = append(tr.recordsForAutoMode, inrecAndContext.Copy())
return
}
@ -271,9 +271,8 @@ func (tr *TransformerBar) processAuto(
// The first pass computes lo and hi from the data
onFirst := true
for e := tr.recordsForAutoMode.Front(); e != nil; e = e.Next() {
recordAndContexts := e.Value.(*types.RecordAndContext)
record := recordAndContexts.Record
for _, recordAndContext := range tr.recordsForAutoMode {
record := recordAndContext.Record
mvalue := record.Get(fieldName)
if mvalue == nil {
continue
@ -301,8 +300,7 @@ func (tr *TransformerBar) processAuto(
slo := fmt.Sprintf("%g", lo)
shi := fmt.Sprintf("%g", hi)
for e := tr.recordsForAutoMode.Front(); e != nil; e = e.Next() {
recordAndContext := e.Value.(*types.RecordAndContext)
for _, recordAndContext := range tr.recordsForAutoMode {
record := recordAndContext.Record
mvalue := record.Get(fieldName)
if mvalue == nil {
@ -333,10 +331,7 @@ func (tr *TransformerBar) processAuto(
}
}
for e := tr.recordsForAutoMode.Front(); e != nil; e = e.Next() {
recordAndContext := e.Value.(*types.RecordAndContext)
outputRecordsAndContexts.PushBack(recordAndContext)
}
outputRecordsAndContexts = append(outputRecordsAndContexts, tr.recordsForAutoMode...)
outputRecordsAndContexts = append(outputRecordsAndContexts, inrecAndContext) // Emit the end-of-stream marker
}