diff options
| author | Martin Czygan <martin.czygan@gmail.com> | 2021-04-24 14:18:11 +0200 |
|---|---|---|
| committer | Martin Czygan <martin.czygan@gmail.com> | 2021-04-24 14:18:11 +0200 |
| commit | 1cf6d135f274ce79b09a0396367186132bc178f3 (patch) | |
| tree | c7070828c8e3f064a94f1be7432e06a9a4f6d26c /skate/cmd | |
| parent | e7f8c117c3586c6387a744043ad68c1850471719 (diff) | |
| download | refcat-1cf6d135f274ce79b09a0396367186132bc178f3.tar.gz refcat-1cf6d135f274ce79b09a0396367186132bc178f3.zip | |
wip: mapper with arbitrary number of fields
Diffstat (limited to 'skate/cmd')
| -rw-r--r-- | skate/cmd/skate-map/main.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/skate/cmd/skate-map/main.go b/skate/cmd/skate-map/main.go index c5fb798..e72cc0c 100644 --- a/skate/cmd/skate-map/main.go +++ b/skate/cmd/skate-map/main.go @@ -25,9 +25,9 @@ var ( func main() { flag.Parse() // XXX: introduce prefixes - availableMappers := map[string]skate.Mapper{ + availableMappers := map[string]skate.FieldMapper{ "id": skate.Identity, - "ff": skate.CreateFixedFieldFunc(*extraValue), + "ff": skate.CreateFixedMapper(*extraValue), "title": skate.MapperTitle, "tnorm": skate.MapperTitleNormalized, "tnysi": skate.MapperTitleNysiis, @@ -36,9 +36,9 @@ func main() { switch { case *mapperName != "": if f, ok := availableMappers[*mapperName]; !ok { - log.Fatal("unknown mapper name: %v", *mapperName) + log.Fatalf("unknown mapper name: %v", *mapperName) } else { - pp := parallel.NewProcessor(os.Stdin, os.Stdout, f) + pp := parallel.NewProcessor(os.Stdin, os.Stdout, f.TSV) pp.NumWorkers = *numWorkers pp.BatchSize = *batchSize pp.Verbose = *verbose |