Re: Using the Local Client from a riak-attach session

2013-01-21 Thread Bryan Fink
On Fri, Jan 18, 2013 at 11:48 AM, Evan Vigil-McClanahan wrote: > Note that this uses the luke mapreduce subsystem, which isn't a good > idea as it's been deprecated going forward. > > Unfortunately there doesn't seem to be a way that's as simple to do > pipe mapreduce jobs. I'll ping people and s

Re: Using the Local Client from a riak-attach session

2013-01-18 Thread Daniil Churikov
But if I need to call 2i query from inside of another mapreduce job (from erlang module), how could I use riakc_pb_socket? -- View this message in context: http://riak-users.197444.n3.nabble.com/Using-the-Local-Client-from-a-riak-attach-session-tp4026572p4026584.html Sent from the Riak Users ma

Re: Using the Local Client from a riak-attach session

2013-01-18 Thread Christian Dahlqvist
Hi Derek, The Riak Erlang client (https://github.com/basho/riak-erlang-client) has good support for mapreduce, so it may be worthwhile switching to this. Here is an example of how to count records returned by a 2i lookup using a map reduce query: riakc_pb_socket:mapred(Pid, {index, <<"bucket"

Re: Using the Local Client from a riak-attach session

2013-01-18 Thread Evan Vigil-McClanahan
Note that this uses the luke mapreduce subsystem, which isn't a good idea as it's been deprecated going forward. Unfortunately there doesn't seem to be a way that's as simple to do pipe mapreduce jobs. I'll ping people and see if we can't get you all some code that's slightly easier to use. On F

Re: Using the Local Client from a riak-attach session

2013-01-18 Thread Derek Sanderson
I love this mailing list Thank you Daniil! I had almost exactly the first thing you recommended, but the example I found had a slightly different notation, and was throwing errors that I couldn't figure out. Your example seems to be working, and I think I can get past my issue Thanks again On T

Re: Using the Local Client from a riak-attach session

2013-01-17 Thread Daniil Churikov
{ok, C} = riak:local_client(), {ok, Keys} = C:get_index(

Re: Using the Local Client from a riak-attach session

2013-01-17 Thread Daniil Churikov
Another option, if you want range query: {ok, C} = riak:local_client(), {ok, Keys} = C:get_index(<<"bucket_name">>, {range, <<"key_name_bin">>, KeyStart, KeyTo}), ... -- View this message in context: http://riak-users.197444.n3.nabble.com/Using-the-Local-Client-from-a-riak-attach-s