18 Commits

Author	SHA1	Message	Date
Kevin Wan	6c2abe7474	fix: goroutine stuck on edge case (#1495) ... * fix: goroutine stuck on edge case * refactor: simplify mapreduce implementation	2022-01-30 13:09:21 +08:00
Kevin Wan	14a902c1a7	feat: handling panic in mapreduce, panic in calling goroutine, not inside goroutines (#1490) ... * feat: handle panic * chore: update fuzz test * chore: optimize square sum algorithm	2022-01-28 10:59:41 +08:00
Kevin Wan	8d6d37f71e	remove unnecessary drain, fix data race (#1435) ... * remove unnecessary drain, fix data race * chore: fix parameter order * refactor: rename MapVoid to ForEach in mr	2022-01-11 16:17:51 +08:00
Kevin Wan	ea4f2af67f	fix: mr goroutine leak on context deadline (#1433) ... * fix: mr goroutine leak on context deadline * test: update fx test check	2022-01-10 22:06:10 +08:00
Kevin Wan	a91c3907a8	feat: rename module from tal-tech to zeromicro (#1413)	2022-01-04 15:51:32 +08:00
Kevin Wan	fe1da14332	chore: simplify mapreduce (#1401)	2022-01-01 19:24:35 +08:00
Kevin Wan	c0647f0719	feat: support context in MapReduce (#1368)	2021-12-25 20:42:52 +08:00
Kevin Wan	d0f9e57022	fix #957 (#959)	2021-08-26 16:47:28 +08:00
Kevin Wan	a87978568a	fix #676 (#682)	2021-05-10 23:10:57 +08:00
heyanfu	7405d7f506	spelling mistakes (#634)	2021-04-17 20:15:19 +08:00
Kevin Wan	bbb9126302	fix golint issues in core/mr (#500)	2021-02-22 09:47:06 +08:00
kevin	f994e1df1a	add more tests	2020-09-16 20:03:30 +08:00
kevin	df37597ac3	simplify mapreduce code	2020-09-16 16:48:59 +08:00
kevin	a8fb010333	drain pipe if reducer not drained	2020-09-12 17:13:32 +08:00
kevin	e987eb60d3	fix mapreduce problem when reducer doesn't write	2020-09-06 18:13:42 +08:00
kevin	0a7e0cce77	update package reference	2020-08-08 16:40:10 +08:00
kevin	8c7f871f89	refactor	2020-07-29 23:15:05 +08:00
kevin	dc744766a9	rename mapreduce to mr	2020-07-29 22:34:37 +08:00