mapreduce

Overview ¶

Example mapreduce: a dynamic fan-out over a list computed at run time.

The map node runs one task per element of `input.docs` (at most 4 at a time); each instance sees its element as `item`. Outputs are collected in order in results.count, and every instance merges its word counts into the `words` channel and adds to `total` — the reduce step is just the reducers.

go run ./examples/mapreduce