Skip to content

Latest commit

 

History

History

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
 
 
 
 

MapReduce Workflow

Example workflow that fans out many map tasks and then submits reduce tasks that depend on the map tasks.

  • main.go contains the task definitions, submits a job, and then starts a task runner to execute it.

Run the example:

go run ./examples/workflows/mapreduce