 SongZihuan
|
ce3e177cad
feat: 经过若干适配
|
hai 1 ano |
 Kevin Wan
|
464ed51728
feat: mapreduce generic version (#2827)
|
%!s(int64=2) %!d(string=hai) anos |
|
Kevin Wan
|
ae87114282
chore: change interface{} to any (#2818)
|
%!s(int64=2) %!d(string=hai) anos |
 cui fliter
|
fc59aec2e7
fix a few function names on comments (#2496)
|
%!s(int64=2) %!d(string=hai) anos |
|
Kevin Wan
|
d978563523
fix: more accurate panic message on mapreduce (#2311)
|
%!s(int64=2) %!d(string=hai) anos |
 wxc
|
d200ba4a7b
feat: CompareAndSwapInt32 may be better than AddInt32 (#2077)
|
%!s(int64=2) %!d(string=hai) anos |
 NoTryNoSuccess
|
fb519fa547
core/mr:a little optimization for collector initialization in ForEach function (#1937)
|
%!s(int64=2) %!d(string=hai) anos |
|
Kevin Wan
|
6c2abe7474
fix: goroutine stuck on edge case (#1495)
|
%!s(int64=3) %!d(string=hai) anos |
|
Kevin Wan
|
14a902c1a7
feat: handling panic in mapreduce, panic in calling goroutine, not inside goroutines (#1490)
|
%!s(int64=3) %!d(string=hai) anos |
|
Kevin Wan
|
8d6d37f71e
remove unnecessary drain, fix data race (#1435)
|
%!s(int64=3) %!d(string=hai) anos |
|
Kevin Wan
|
ea4f2af67f
fix: mr goroutine leak on context deadline (#1433)
|
%!s(int64=3) %!d(string=hai) anos |
|
Kevin Wan
|
a91c3907a8
feat: rename module from tal-tech to zeromicro (#1413)
|
%!s(int64=3) %!d(string=hai) anos |
|
Kevin Wan
|
fe1da14332
chore: simplify mapreduce (#1401)
|
%!s(int64=3) %!d(string=hai) anos |
|
Kevin Wan
|
c0647f0719
feat: support context in MapReduce (#1368)
|
%!s(int64=3) %!d(string=hai) anos |
|
Kevin Wan
|
d0f9e57022
fix #957 (#959)
|
%!s(int64=3) %!d(string=hai) anos |
|
Kevin Wan
|
a87978568a
fix #676 (#682)
|
%!s(int64=4) %!d(string=hai) anos |
 heyanfu
|
7405d7f506
spelling mistakes (#634)
|
%!s(int64=4) %!d(string=hai) anos |
|
Kevin Wan
|
bbb9126302
fix golint issues in core/mr (#500)
|
%!s(int64=4) %!d(string=hai) anos |
|
kevin
|
f994e1df1a
add more tests
|
%!s(int64=4) %!d(string=hai) anos |
|
kevin
|
df37597ac3
simplify mapreduce code
|
%!s(int64=4) %!d(string=hai) anos |
|
kevin
|
a8fb010333
drain pipe if reducer not drained
|
%!s(int64=4) %!d(string=hai) anos |
|
kevin
|
e987eb60d3
fix mapreduce problem when reducer doesn't write
|
%!s(int64=4) %!d(string=hai) anos |
|
kevin
|
0a7e0cce77
update package reference
|
%!s(int64=4) %!d(string=hai) anos |
|
kevin
|
8c7f871f89
refactor
|
%!s(int64=4) %!d(string=hai) anos |
|
kevin
|
dc744766a9
rename mapreduce to mr
|
%!s(int64=4) %!d(string=hai) anos |
