Another approach for pooling riak pb client connections

a single node. The take_member function randomly selects a pool to draw from giving simple load-balancing among Riak nodes. - Written as an OTP application. To use it, you add config for the pooler application and call application:start(pooler). Feedback most welcome. + seth -- Seth Falc

Re: Multiple disks

, each pointed at its own disk. + seth -- Seth Falcon | @sfalcon | http://userprimary.net/ ___ riak-users mailing list riak-users@lists.basho.com http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com

Re: running erlang map phases via REST API

On Thu, Jan 27, 2011 at 12:15 AM, Dan Reverri wrote: > This commit looks interesting. A lot of changes were made to map reduce in > 0.14 so I am not sure it will work in it's current form. > I think we would only need to include the changes in riak_kv_mapred_json.erl > and riak_kv_mapred_query.erl

Re: Erlang API vs Erlang PBC

or > more processes could use the same conn at a given time (side question: is > that a problem?). Yes, I believe that is a problem. Each pb client will have a unique client ID used in the vector clock. You want to avoid the same client ID from making concurrent modifications. + seth -- Seth Fa

Re: running erlang map phases via REST API

Hi all, I too would find this useful. And a while back I wrote a patch that enabled it. I'm afraid the patch has likely suffered bit rot, but the ideas can at least be harvested: https://issues.basho.com/show_bug.cgi?id=806 http://github.com/seth/riak_kv + seth -- Seth Falcon | @sf

Re: loading erlang terms

rms(Tokens = [_H|_T], Acc) -> {TermTokens, Rest} = pop_term(Tokens), split_by_terms(Rest, [TermTokens|Acc]); split_by_terms([], Acc) -> lists:reverse(Acc). -- Seth Falcon | @sfalcon | http://userprimary.net/ ___ riak-users mailing list riak-users@lists.basho.com http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com

Re: loading erlang terms

27;s native binary term serialization. B = term_to_binary(Terms), % now store B in Riak % ... % now get B out and do: binary_to_term(B) + seth -- Seth Falcon | @sfalcon | http://userprimary.net/ ___ riak-users mailing list riak-users@lists.basho.com htt

Re: Ping: Using Erlang funs for map reduce via the REST API and protocol buffers client

sues.basho.com/show_bug.cgi?id=806 + seth -- Seth Falcon | @sfalcon | http://userprimary.net/ ___ riak-users mailing list riak-users@lists.basho.com http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com

Re: Ping: Using Erlang funs for map reduce via the REST API and protocol buffers client

For now, I updated my branch on github rebased against latest riak_kv. http://github.com/seth/riak_kv/commits/master + seth -- Seth Falcon | @sfalcon | http://userprimary.net/ ___ riak-users mailing list riak-users@lists.basho.com http://lists.

Ping: Using Erlang funs for map reduce via the REST API and protocol buffers client

er}, unset, true}]). I posted a note about this to the list a month ago, but haven't received any response. Curious if this is of interest to other users. Basho team, comments? Link to original post: http://lists.basho.com/pipermail/riak-users_lists.basho.com/2010-

Re: erlang mapReduce

ocket:ping(Pid). > than there is no output and the erlang shell is not responding > anymore ... (probably a timeout) Make sure your are using the correct port and try again. That may be the root cause of the issues you are seeing. + seth -- Seth Falcon | @sfalcon | http://userprimary.net/

Using Erlang funs for map reduce via the REST API and protocol buffers client

spending any more time on it -- perhaps there are other issues with this approach that I'm not aware of or a more elegant solution... BTW, the inspiration for the approach came from this post by the Erjang developer: http://www.javalimit.com/2010/05/passing-funs-to-other-erlan

Re: Riak and no of clients limit?

think that this is not an intended use). Given that, it sounds like one would want a pool of pb clients such that each resource takes a client out of the pool when handling a request and returns it when done. So there would be no concurrent requests going through the same client. Does tha

Re: Riak and no of clients limit?

ter as part of the webmachine startup. Then the resources in the webmachine app ask for one of these clients for each request. Your comment above about reusing clients for non-concurrent requests makes me wonder if this is the wrong approach. Comments or suggestions? Thanks,

Re: Small patch to fix bin/riak stop on OS X

> approach is better or more portable than the other, just letting you know > what's up. > Original bug is here: https://issues.basho.com/show_bug.cgi?id=63 > commit is here: http://bitbucket.org/basho/riak/changeset/c27fc73ef47d Works for me :-) Thanks all. + seth --

Re: Small patch to fix bin/riak stop on OS X

#x27;m doing it all wrong :-P ). Cheers, + seth -- Seth Falcon | @sfalcon | http://userprimary.net/ ___ riak-users mailing list riak-users@lists.basho.com http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com

Small patch to fix bin/riak stop on OS X

] [-U user[,user...]] ps [-L] ok It seems that ps -f is not supported (indeed illegal!) on OS X. The following change works for me and I believe will work just as well on Linux. commit 82c6d30085ef38fcd97abc5e5293f9f4644f3092 Author: Seth Falcon Date: Thu Jul 1 20:09:57 2010 -0700 Fix