Thanks for your answers. Now, it seems that if the items passing between the map phase and reduce phase are many and small, then the system could benefit from a "chunking" fitting that collects items and sends them off in a list to the next fitting, after receiving X # of items, or after some timeout (say, Y ms); i.e. basically Nagle's algorithm Otherwise, we may get burned pretty seriously by the "sync send" that happens between fittings !?
So ... { list_keys, riak_kv_get, follow riak_kv_mrc_map, follow nagles_send, follow nagles_receive, riak_pipe_w_reduce:chashfun riak_pipe_w_reduce, follow } On Nov 30, 2011, at 4:08 PM, Bryan Fink wrote: > Ew. Major apologies for the formatting in my last response. I've no > idea what happened. Let me know if it's unreadable, and I'll try > sending again. > > -Bryan _______________________________________________ riak-users mailing list riak-users@lists.basho.com http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com