mapreduce-go

A simple MapReduce framework for distributed computing in Go.

This project demonstrates:

• Dynamic workers that can crash
• RPC communication over Unix sockets
• Plugin-based map and reduce functions
• Fault-tolerant MapReduce execution

Running

go build -buildmode=plugin ./apps/wc
go run ./cmd/master ./mapreduce/*.go
go run ./cmd/worker -plugin wc.so