0

我已经完成了以下操作。我已经存储了如下详细信息，但即使我在 mapreduce 中遇到错误，请帮助我。我想要 test_age 存储桶的数据。显示 {gopi,1}。

1> {ok, Pid} = riakc_pb_socket:start_link('127.0.0.1',10017).
{ok,<0.34.0>}
2> Object = riakc_obj:new(<<"test_age">>, <<"test1">>, <<"gopi & 1">>). 
{riakc_obj,<<"test_age">>,<<"test1">>,undefined,[],
       undefined,<<"gopi & 1">>}
3> riakc_pb_socket:put(Pid,Object).
ok 
4> Mapf = fun(Obj,_,_) -> [{I,1}|| I <- binary_to_term(riak_object:get_value(Object))]   end. 
#Fun<erl_eval.18.82930912>
5> {ok, [{0,[R]}]} = riakc_pb_socket:mapred(Pid,<<"test_age">>,[{map,{qfun,Mapf},none,true}])
5> .
** exception error: no match of right hand side value {error,<<"{\"phase\":0,\"error\":\"function_clause\",\"input\":\"{ok,{r_object,<<\\\"test_age\\\">>,<<\\\"test1\\\">>,[{r_content,{dict"...>>}

我做错了我无法弄清楚的地方。请

4

1 回答 1

0

问题在于您的地图功能：

Mapf = fun(Obj,_,_) -> [{I,1}|| I <- binary_to_term(riak_object:get_value(Object))] end.

当它执行时，Obj将包含 r_object 记录，但Object将是未定义的。您可能打算使用：

Mapf = fun(Obj,_,_) -> [{I,1}|| I <- binary_to_term(riak_object:get_value(Obj))] end.

您存储的值<<"gopi & 1">>是调用binary_to_term. 那么列表理解是有效[{I,1}|| I <- <<"gopi & 1">>]的，它会抛出一个 bad_generator 错误。为了使用这个 map 函数，所有的值都需要是 Erlang 列表。

于 2014-05-19T20:01:21.190 回答