A in-process MapReduce library to help you optimizing service response time or concurrent task processing.
Full Changelog: https://github.com/kevwan/mapreduce/compare/v2.1.0...v2.1.1
Non-generic version.
Generics version now goes default.
Generics version.
Handled panics in mapper and reducer functions.
Panics will panic in the calling goroutines.
ForEach
method.Handled panics in mapper and reducer functions.
Panics will panic in the calling goroutine.
Handled panics in mapper and reducer functions.
Panics will panic in the calling goroutine.
First release of generics version.
import "github.com/kevwan/mapreduce/v2
Simplified the code.
Removed AtomicError and DoneChan for easy reading.
The first release of the separate mapreduce
repo.
Check out more examples from https://github.com/zeromicro/zero-examples/tree/main/mapreduce