aboutsummaryrefslogtreecommitdiffstats
path: root/skate
diff options
context:
space:
mode:
authorMartin Czygan <martin.czygan@gmail.com>2021-08-03 00:46:12 +0200
committerMartin Czygan <martin.czygan@gmail.com>2021-08-03 00:46:12 +0200
commit730612615d6c3919f98cbb5aeaa9956b8b1a65c7 (patch)
treec99afb718f110bd4b55d487238afae550531e5e5 /skate
parent26531d7becbf37f8e79681af304ec8a67efc9bf7 (diff)
downloadrefcat-730612615d6c3919f98cbb5aeaa9956b8b1a65c7.tar.gz
refcat-730612615d6c3919f98cbb5aeaa9956b8b1a65c7.zip
update docs
Diffstat (limited to 'skate')
-rw-r--r--skate/map.go2
1 files changed, 2 insertions, 0 deletions
diff --git a/skate/map.go b/skate/map.go
index 34e2f2c..ca98186 100644
--- a/skate/map.go
+++ b/skate/map.go
@@ -113,6 +113,8 @@ type Mapper func([]byte) ([][]byte, error)
// AsTSV serializes the result of a field mapper as TSV. This is a slim
// adapter, e.g. to parallel.Processor, which expects this function signature.
// A newline will be appended, if not there already.
+//
+// Anecdotally a parallelized implementation of a mapper can process around 300MiB/s.
func (f Mapper) AsTSV(p []byte) ([]byte, error) {
var (
fields [][]byte