Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Commits on Nov 12, 2012
  1. @beerriot

    remove luke usage

    beerriot authored
    riak_pipe powers MapReduce queries now
Commits on Jul 14, 2011
  1. @Vagabond

    Switch to lager logging API

    Vagabond authored
Commits on Apr 26, 2011
  1. @kellymclaughlin

    Add Reply parameter to handle_not_found_reply so that the notfound er…

    kellymclaughlin authored
    …rors
    
    are present if requested by the client.
    
    tags: az327
    
    The fix to address bz1006 causes notfound error information to be excluded
    from the results of a MapReduce even if the inclusion is requested by
    the client. This changes corrects that by adding a Reply parameter to
    the handle_not_found_reply function and ensuring that after the
    final preference list entry has been checked that Reply is appended
    to the phase state's pending value.
    
    Add test cases for riak_kv_mapreduce:map_object_value to show that
    the include_notfound and filter_notfound actions work as expected.
Commits on Jan 27, 2011
  1. @beerriot
  2. @beerriot

    reduce function to be used in computing key counts

    beerriot authored
    The intention of this patch is to provide a suitable function for
    counting the keys in a bucket via keylist+map/reduce.  Using this
    function saves bandwidth over counting on the client side (with
    ?keys=stream, for example) because keys are never sent to the client.
    Using this function saves I/O over a query including a map phase because
    the values stored under the keys are never read from disk.
    
    A few ways to use this function:
    
    Riak console:
    
        {ok, [KeyCount]} =
            C:mapred(<<"my_bucket">>,
                     [riak_kv_mapreduce:reduce_count_inputs(true)]).
    
    HTTP (response body is a 1-element JSON list):
    
        $ curl -X POST -H "content-type:application/json" \
          http://localhost:8098/mapred --data @-
        {"inputs":"my_bucket",
         "query":[{"reduce":{"language":"erlang",
                             "module":"riak_kv_mapreduce",
                             "function":"reduce_count_inputs",
                             "keep":true}}]}
    
    HTTP with key filters:
    
        $ curl -X POST -H "content-type:application/json" \
          http://localhost:8098/mapred --data @-
        {"inputs":{"bucket":"my_bucket",
                   "key_filters":[["starts_with","f"]]},
         "query":[{"reduce":{"language":"erlang",
                             "module":"riak_kv_mapreduce",
                             "function":"reduce_count_inputs",
                             "keep":true}}]}
Commits on Dec 20, 2010
  1. @beerriot

    configurable notfound handling for riak_kv_mapreduce map functions (b…

    beerriot authored
    …z://933)
    
    These improve testability of the map/reduce system.  See the
    mapred_verify project for example usage.
  2. @beerriot

    add match to riak_kv_mapreduce not_found filter (bz://933)

    beerriot authored
    The format of the inter-phase not_found map result changed. The reduce
    functions in this module will fail with badarith without this change.
Commits on Nov 29, 2010
  1. @lemenkov

    Do not expose testing API when it isn't required

    lemenkov authored
    Signed-off-by: Peter Lemenkov <lemenkov@gmail.com>
Commits on Oct 6, 2010
  1. Add missing semi-colon.

    Rusty Klophaus authored
Commits on Oct 5, 2010
  1. Add reduce_identity/N functions to riak_kv_mapreduce.erl. (Currently …

    Rusty Klophaus authored
    …used to reflect back the incoming list of BKey inputs.)
Commits on Jul 22, 2010
  1. @argv0

    initial import

    argv0 authored
Something went wrong with that request. Please try again.