Map reduce starts out as a multiget. If your reduce function is a union of
all data and map is an identity you just have a multiget.
What I use:
B - bucket,
LI - list of keys
mget_bin(P,B,LI) ->
case riakc_pb_socket:mapred(P,[{B,key(Key)} || Key <- LI],
[{reduce, {modfun, riak_kv_mapreduce, reduce_set_union}, none, false},
{map, {modfun, riak_kv_mapreduce, map_identity}, none, true}]) of
{ok,[{_,L}|_]} ->
{ok,[Val ||
{r_object,_Bucket,_Key,[{r_content,_Meta,Val}],_VClock,_UpdateMeta,_UpdateVal}
<- L]};
{error,notfound} ->
undefined;
X ->
X
end.
Sergej
On Sun, Sep 23, 2012 at 9:44 AM, Pavel Kogan <pavel.ko...@cortica.com>wrote:
> Hi all,
>
> Is there any multiget functionality in Riak (like in memcached)?
>
> Best Regards,
> Pavel
>
> _______________________________________________
> 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
