anchor.diff:           stream_list_buckets/1,
            list_keys/2,
            stream_list_keys/2,
  -         mapred/3,
  -         mapred/4,
  -         mapred_stream/5]).
  +         mapred/3, mapred/4,
  +         mapred_stream/5,
  +         mapred_bucket/3, mapred_bucket/4,
  +         mapred_bucket_stream/5]).
  +
   -export([init/1, handle_call/3, handle_cast/2, handle_info/2,
            terminate/2, code_change/3]).
   
  
positive.code: %%              Query :: [riak_kv_mapred_query:mapred_queryterm()],
  %%              TimeoutMillisecs :: integer()  | 'infinity') ->
  %%       {ok, riak_kv_mapred_query:mapred_result()} |
  %%       {error, {bad_qterm, riak_kv_mapred_query:mapred_queryterm()}} |
  %%       {error, timeout} |
  %%       {error, Err :: term()}
  %% @doc Perform a map/reduce job across the cluster.
  
negative.code: %%                                        undefined, true}]),
  %%     ?assertEqual(lists:sort(Results), ["2", "3", "4"]).
  
  -endif.
  
  