diff options
author | Martin Czygan <martin.czygan@gmail.com> | 2021-04-26 18:39:55 +0200 |
---|---|---|
committer | Martin Czygan <martin.czygan@gmail.com> | 2021-04-26 18:39:55 +0200 |
commit | f4d0387f9ec190caab96b952762bc999d1ad63aa (patch) | |
tree | a906f4ce10e7f6b7a9e35cfd9a5b3c683b54cb52 /skate/map.go | |
parent | faea941faff358802a8950af54d05ac88264b8f3 (diff) | |
download | refcat-f4d0387f9ec190caab96b952762bc999d1ad63aa.tar.gz refcat-f4d0387f9ec190caab96b952762bc999d1ad63aa.zip |
rename FieldMapper to Mapper
In our context, we are for now only mapping a blob to a number of
fields.
Diffstat (limited to 'skate/map.go')
-rw-r--r-- | skate/map.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/skate/map.go b/skate/map.go index 9cad1e4..2cb4ebc 100644 --- a/skate/map.go +++ b/skate/map.go @@ -31,13 +31,13 @@ type PartialDoc struct { Year string `json:"release_year"` } -// FieldMapper maps a blob to an arbitrary number of fields, e.g. for (key, +// Mapper maps a blob to an arbitrary number of fields, e.g. for (key, // doc). We want fields, but we do not want to bake in TSV into each function. -type FieldMapper func([]byte) ([][]byte, error) +type Mapper func([]byte) ([][]byte, error) // TSV serialized the result of a field mapper as TSV. This is a slim adapter, // e.g. to parallel.Processor, which expects this function signature. -func (f FieldMapper) TSV(p []byte) ([]byte, error) { +func (f Mapper) TSV(p []byte) ([]byte, error) { fields, err := f(p) if err != nil { return nil, err @@ -63,7 +63,7 @@ func Identity(p []byte) ([][]byte, error) { // CreateFixedMapper extract the value from a given fixed top level json key. // Returns a function that maps doc to (v, doc). -func CreateFixedMapper(field string) FieldMapper { +func CreateFixedMapper(field string) Mapper { f := func(p []byte) ([][]byte, error) { var ( doc map[string]interface{} |