<html><head></head><body style="word-wrap: break-word; -webkit-nbsp-mode: space; -webkit-line-break: after-white-space; ">Excellent -- that helped a great deal.<div><br></div><div>For those who may search in the future the most important thing is to have the output of your final step (a reduce in my case) be a list of {Key :: Binary, Value :: json_term()} as Bob identified below.  </div><div><br></div><div>In a standard map reduce that means the input to the reduce step and the output of the map step must also be that same data structure.  So by converting the dictionary in my map step to a string, and doing some from_list, to_list magic in the reduce I was able to achieve my goal.</div><div><br></div><div>Here's my newbie looking (but working!) code for those interested in the details:</div><div><br></div><div><div><font class="Apple-style-span" face="'Courier New'">emitStatsFromList(G, undefined, none)-></font></div><div><font class="Apple-style-span" face="'Courier New'">    ObjectJson = riak_object:get_value(G),</font></div><div><font class="Apple-style-span" face="'Courier New'">    {array, ListOfStructs} = mochijson:decode(ObjectJson),</font></div><div><font class="Apple-style-span" face="'Courier New'">    [{getMrKey(I), 1} || I <- ListOfStructs].</font></div><div><font class="Apple-style-span" face="'Courier New'"><br></font></div><div><font class="Apple-style-span" face="'Courier New'">getMrKey(StructItem)-></font></div><div><font class="Apple-style-span" face="'Courier New'">    {struct, DocPropList} = StructItem,</font></div><div><font class="Apple-style-span" face="'Courier New'">    SList = [proplists:get_value("obj_name",DocPropList,"None"),</font></div><div><font class="Apple-style-span" face="'Courier New'">             proplists:get_value("type",DocPropList,"None"),</font></div><div><font class="Apple-style-span" face="'Courier New'">             proplists:get_value("obj_url",DocPropList,"None"),</font></div><div><font class="Apple-style-span" face="'Courier New'">             "hourly"],</font></div><div><font class="Apple-style-span" face="'Courier New'">    string:join(SList, ",").</font></div><div><font class="Apple-style-span" face="'Courier New'"><br></font></div><div><font class="Apple-style-span" face="'Courier New'">reduceStatsList(Gcounts, none)-></font></div><div><font class="Apple-style-span" face="'Courier New'">    GC = [dict:from_list(Gcounts)],</font></div><div><font class="Apple-style-span" face="'Courier New'">    Update = [lists:foldr(fun(G, Acc)->dict:merge(fun(_, X, Y) -> X+Y end,G, Acc) end,</font></div><div><font class="Apple-style-span" face="'Courier New'">                 dict:new(),</font></div><div><font class="Apple-style-span" face="'Courier New'">                 GC)],</font></div><div><font class="Apple-style-span" face="'Courier New'">    [OutputList] = [dict:to_list(I) || I <- Update],</font></div><div><font class="Apple-style-span" face="'Courier New'">    OutputList.</font></div></div><div><br></div><div><div>Thanks again,</div><div><br></div><div>John</div></div><div><br></div><div><br><div><div>On Jun 5, 2012, at 2:27 PM, Bob Ippolito wrote:</div><br class="Apple-interchange-newline"><blockquote type="cite"><div class="gmail_quote">On Tue, Jun 5, 2012 at 1:22 PM, John Roy <span dir="ltr"><<a href="mailto:john@thoughtleadr.com" target="_blank">john@thoughtleadr.com</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
<div style="word-wrap:break-word">I saw something similar from an individual who was using javascript (<a href="http://lists.basho.com/pipermail/riak-users_lists.basho.com/2011-July/004843.html" target="_blank">http://lists.basho.com/pipermail/riak-users_lists.basho.com/2011-July/004843.html</a>), but I don't think I have the same problem in erlang.  Any help is greatly appreciated.<div>
<br></div><div>I'm consistently getting the following error from my curl map reduce calls:<div><br></div><div><font face="'Courier New'">{error,{exit,{json_encode,{bad_term,..</font></div><div><font face="'Courier New'"><br>
</font></div><div>output dictionary here, then:</div><div><font face="'Courier New'"><br></font></div><div><font face="'Courier New'"><div>        [{mochijson2,json_encode,2},</div><div>         {mochijson2,'-json_encode_array/2-fun-0-',3},</div>
<div>         {lists,foldl,3},</div><div>         {mochijson2,json_encode_array,2},</div><div>         {riak_kv_wm_mapred,pipe_mapred_nonchunked,5},</div><div>         {webmachine_resource,resource_call,3},</div><div>         {webmachine_resource,do,3},</div>
</font></div><div><font face="'Courier New'"><br></font></div><div>The term that follows the error appears to the correct result of the map reduce.</div><div><br></div><div>I'm just trying the mr locally for testing purposes.  I'm using eleveldb backend and riak (1.1.2 2012-04-17) OSX x86_64.</div>
<div><br></div><div>Here's the curl command:</div><div><br></div><div><font face="'Courier New'">curl -v -X POST <a href="http://127.0.0.1:8098/mapred" target="_blank">http://127.0.0.1:8098/mapred</a> -H "Content_Type: application/json" -d @query.js</font></div>
<div><br></div><div>and the query.js:</div><div><br></div><div><div><font face="'Courier New'">{</font></div><div><font face="'Courier New'">    "inputs" : {</font></div><div><font face="'Courier New'">        "bucket" : "test7",</font></div>
<div><font face="'Courier New'">        "index" : "field1_int",</font></div><div><font face="'Courier New'">        "start" : 0,</font></div><div><font face="'Courier New'">        "end" : 23</font></div>
<div><font face="'Courier New'">    },</font></div><div><font face="'Courier New'">    "query" : [</font></div><div><font face="'Courier New'">        { "map" : {"language" : "erlang", "module" : "impressions", "function" : "emitStats", "keep" : false} },</font></div>
<div><font face="'Courier New'">        { "reduce" : {"language" : "erlang", "module" : "impressions", "function" : "reduceStats", "keep" : true} }</font></div>
<div><font face="'Courier New'">    ],</font></div><div><font face="'Courier New'">    "timeout" : 600000</font></div><div><font face="'Courier New'">}</font></div></div><div><br></div><div>
and finally the associated erlang functions:</div><div><br></div><div><div><font face="'Courier New'">emitStats(G, undefined, none)-></font></div><div><font face="'Courier New'">    ObjectJson = riak_object:get_value(G),</font></div>
<div><font face="'Courier New'">    {struct, DocPropList} = mochijson:decode(ObjectJson),</font></div><div><font face="'Courier New'">    I = {proplists:get_value("obj_name",DocPropList,"None"),</font></div>
<div><font face="'Courier New'">         proplists:get_value("type",DocPropList,"None"),</font></div><div><font face="'Courier New'">         proplists:get_value("obj_url",DocPropList,"None"),</font></div>
<div><font face="'Courier New'">         "hourly"},</font></div><div><font face="'Courier New'">    [dict:from_list([{I,1}])].</font></div><div><font face="'Courier New'"><br></font></div>
<div><font face="'Courier New'">reduceStats(Gcounts, none)-></font></div><div><font face="'Courier New'">    [lists:foldr(fun(G, Acc)->dict:merge(fun(_, X, Y) -> X+Y end,G, Acc) end,</font></div><div>
<font face="'Courier New'">                 dict:new(),</font></div><div><font face="'Courier New'">                 Gcounts)].</font></div></div></div></div></blockquote><div><br></div>I don't have any experience with Riak's MR implementation, but mochijson2 does not have any native support for serializing dict, and JSON itself doesn't support keys that are not strings, and I suspect that one or both of those may be your problem. mochijson2 expects to see {struct, [{Key :: binary(), Value :: json_term()}]} for JSON objects.<br>
<br><div>-bob</div><div> </div></div>
</blockquote></div><br></div></body></html>