n/m, I just need to modify my args from [0,15] to
{"reduce_phase_only_1":true,0:10,1:15}*<http://www.loomlearning.com/> Jonathan Langevin Manager, Information Technology Loom Inc. Wilmington, NC: (910) 241-0433 - jlange...@loomlearning.com - www.loomlearning.com - Skype: intel352 * On Wed, Nov 30, 2011 at 10:11 AM, Jonathan Langevin < jlange...@loomlearning.com> wrote: > Excellent tip Sean, works great for a similar issue I was having. > If I already had args being passed to my reduce phase though (such as when > calling Riak.reduceSlice), is it possible to specify only_1 and still > ensure that my regular args pass through to the function as expected? For > instance, reduceSlice expects [int,int], which conflicts with > {"somearg":blah}. > My thought is to now encapsulate my original function call, but I want to > make sure I'm not missing something in Riak that already handles this issue. > > <http://www.loomlearning.com/> > * Jonathan Langevin > Manager, Information Technology > Loom Inc. > Wilmington, NC: (910) 241-0433 - jlange...@loomlearning.com - > www.loomlearning.com - Skype: intel352 * > > > > On Wed, Nov 30, 2011 at 10:01 AM, Sean Cribbs <s...@basho.com> wrote: > >> Hi Yehuda, >> >> Your reduce function is not guaranteed to run across all inputs in the >> first application, but may be applied many times as new inputs come in. >> Riak will batch up reduce inputs until a certain number or timeout is >> reached, then apply the function and take its output to be part of the >> inputs for the next application. If it is absolutely necessary to run the >> reduce function only once, use "reduce_phase_only_1" as the "arg" (only >> works on Riak 1.0.x, example in Ruby): >> >> mr.reduce("function(v){...}", :arg => {:reduce_phase_only_1 => true}, >> :keep => true) >> >> Hope that helps! >> >> On Wed, Nov 30, 2011 at 9:03 AM, Yehuda Zargrov <yeh...@conduit.com>wrote: >> >>> Hi,**** >>> >>> ** ** >>> >>> I’ve posted a mail on this few days ago, but went a bit further since >>> then.**** >>> >>> ** ** >>> >>> I’m using ripple, running a map function on some input and getting a >>> list of about 50 items.**** >>> >>> ** ** >>> >>> Right after that, I’m running a reduce function. The first thing I do in >>> it is putting the length of v (the input) as an item in a list.**** >>> >>> ** ** >>> >>> When printing the result I see that the length is 13.**** >>> >>> ** ** >>> >>> It’s like something has happened between the map and reduce phases.**** >>> >>> ** ** >>> >>> Any ideas?**** >>> >>> ** ** >>> >>> **** >>> >>> [image: Description: >>> C:\Users\Yehuda\AppData\Roaming\Microsoft\Signatures\logo.gif]**** >>> >>> *Yehuda Zargrov** >>> *Software Engineer**** >>> >>> *Conduit Your Site* <http://www.conduit.com/>**** >>> >>> *t:* 972.8.9461713 ext +314 | *m:* +972503473119 | *f:* >>> +97286382140 **** >>> >>> >>> This message may contain confidential and/or privileged information. It >>> is intended to be read only by the individual or entity to whom it is >>> addressed or by their designee. >>> If the reader of this message is not the intended recipient, you are on >>> notice that any uses, copy, disclose or distribution of this message, in >>> any form, is strictly prohibited. >>> If you have received this message in error, please notify the sender by >>> reply email or by telephone and delete or destroy any copy of this message. >>> Thank you. >>> >>> **** >>> >>> _______________________________________________ >>> riak-users mailing list >>> riak-users@lists.basho.com >>> http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com >>> >>> >> >> >> -- >> Sean Cribbs <s...@basho.com> >> Developer Advocate >> Basho Technologies, Inc. >> http://www.basho.com/ >> >> >> _______________________________________________ >> riak-users mailing list >> riak-users@lists.basho.com >> http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com >> >> >
_______________________________________________ riak-users mailing list riak-users@lists.basho.com http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com
