error running Erlang m/r job

Evan Vigil-McClanahan emcclanahan at basho.com
Thu Apr 4 11:14:22 EDT 2013


As of 1.3 the old client:mapreduce is deprecated, please use
`riak_kv_mrc_pipe:mapred` instead.

On Thu, Apr 4, 2013 at 9:07 AM, Tom Zeng <tom at intridea.com> wrote:
> Hi everyone,
>
> I am trying to run the Erlang m/r following the Riak Handbook, and got the
> following error:
>
> (riak at 127.0.0.1)4> ExtractTweet = fun(RObject, _, _) ->
> (riak at 127.0.0.1)4>  {struct, Obj} = mochijson2:decode(
> (riak at 127.0.0.1)4>    riak_object:get_value(RObject)),
> (riak at 127.0.0.1)4>  [proplists:get_value(<<"tweet">>, Obj)]
> (riak at 127.0.0.1)4> end.
> #Fun<erl_eval.18.82930912>
> (riak at 127.0.0.1)5> C:mapred([{<<"tweets">>, <<"41399579391950848">>}],
> (riak at 127.0.0.1)5>   [{map, {qfun, ExtractTweet}, none, true}]).
> ** exception error: undefined function riak_client:mapred/3
>
> I've been using JavaScript for m/r and just started using Erlang per Basho
> engineers' recommendation at Riak DC meetup. Any help/pointers appreciated.
>
> Thanks
> Tom
> --
> Tom Zeng
> Director of Engineering
> Intridea, Inc. | www.intridea.com
> tom at intridea.com
>
>
> _______________________________________________
> riak-users mailing list
> riak-users at lists.basho.com
> http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com
>




More information about the riak-users mailing list