Re: A function as an input for map/reduce

2011-05-07 Thread Justin Sheehy
Hi, Mikhail. On Thu, May 5, 2011 at 5:15 PM, Mikhail Sobolev wrote: > Thank you for the description.  I now wonder if it's possible for a > map-function instead of returning the whole list of results, do > something that Riak would take as "ah! another map result, let's do pass > it to the next

Re: A function as an input for map/reduce

2011-05-05 Thread Mikhail Sobolev
Hi Justin, On Thu, May 05, 2011 at 10:26:19AM -0400, Justin Sheehy wrote: > The "map" part of the MapReduce programming paradigm is not only > inherently parallel, it also does not impose a point of order on the > overall dataflow and thus does not introduce a concurrency barrier. > In practical t

Re: A function as an input for map/reduce

2011-05-05 Thread Justin Sheehy
Hi, Mikhail. On Tue, May 3, 2011 at 5:55 PM, Mikhail Sobolev wrote: > Is there more information about "it can through a few keys at a time, >   and the map/reduce chain would go ahead and start doing the >   processing on whatever keys it gets as soon as it gets them, it does >   not have to w

A function as an input for map/reduce

2011-05-03 Thread Mikhail Sobolev
Hi, I watched "MapReducing Big Data With Riak and Luwak"[1] recorded webinar. And it is based on a possibility to use a function ("dynamic inputs" @ ~8:04 in the video) to actually generate inputs for the query. It raised two questions: 1. Is there a documentation about this kind of function?