This commit is contained in:
John Kerl 2021-06-02 23:42:27 -04:00
parent b08633ca82
commit 333a120b69
2 changed files with 5 additions and 3 deletions

View file

@ -34,6 +34,7 @@ func ChainTransformer(
}
go runSingleTransformer(
i == 0,
ichan,
recordTransformer,
ochan,
@ -42,6 +43,7 @@ func ChainTransformer(
}
func runSingleTransformer(
isFirst bool,
inputChannel <-chan *types.RecordAndContext,
recordTransformer IRecordTransformer,
outputChannel chan<- *types.RecordAndContext,
@ -65,6 +67,7 @@ func runSingleTransformer(
if recordAndContext.EndOfStream == true || recordAndContext.Record != nil {
recordTransformer.Transform(recordAndContext, outputChannel)
// TODO: nr progress mod
} else {
outputChannel <- recordAndContext
}

View file

@ -5,7 +5,6 @@ TOP OF LIST:
! check issues
* --prepipex
* --nr-progress-mod
* mlr -k
@ -32,12 +31,12 @@ w survey
o golang static-analysis tool -- ?
----------------------------------------------------------------
! community page
! how-to-help guide
- testing
- doc mods
- dev
- community
> backport to docs5
! get doc6 going sooner than later! lots accumulating ...
o big:
@ -52,7 +51,7 @@ w survey
- likewise cookbook2/3 -- overly nerdy; perhaps just annoying
- re-work data-sharing <-> SQL ...
o little:
- stats1 -r
- stats1 --fr
cookbook2.rst.in
- mlr --print-type-arithmetic-info
reference.rst.in