erlang - 如何在 Erlang 中编写面向性能的 map/reduce 查询

Question

我在 riak 上运行 Erlang Map/Reduce。在一个存储桶中有 57000 条记录，其中我的映射阶段以 14 秒的时间获取过滤记录。

-module(chatlogs).
-author("gopi").

%% API
-export([getListForUser/3]).


getListForUser(Obj,_kd,Chat_id) ->
case catch mochijson2:decode(hd(riak_object:get_values(Obj))) of
{struct, Data} ->
     Event_list = [<<"INTRO_MSG">>, <<"QUESTION">>, <<"VALID_ANSWER">>,  <<"NEW_MSG">>],
    case proplists:get_value(<<"chat_id">>,Data) == Chat_id  of
    true ->
            case lists:member(proplists:get_value(<<"Event-Name">>,Data),Event_list) of
                    true->
                            [Data];
                    false->
                            []
            end;
    false ->
            []
    end;
_ ->
   []
end.

有没有更好的方法来降低和提高代码性能