aboutsummaryrefslogtreecommitdiffstats
path: root/skate/map.go
diff options
context:
space:
mode:
Diffstat (limited to 'skate/map.go')
-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