gistfile1.txt

[
 %% Riak Core config
 {riak_core, [
        {web_port, 8098},
        {seed, false},
        {volume_size, 128},
        {web_ip, "10.252.89.235"},
        {ring_state_dir, "/mnt/riak/data/ring"},
        {cluster_name, "default"},
        {stripe_action, create}
        ]},
 %% Riak KV config
 {riak_kv, [
        {pb_ip, "0.0.0.0"},
        {mapred_name, "mapred"},
        {riak_kv_stat, true},
        {raw_name, "riak"},
        {storage_backend, riak_kv_bitcask_backend},
        {vnode_cache_entries, 0},
        {handoff_port, 8099},
        {pb_port, 8087},
        {js_vm_count, 16},
        {js_thread_stack, 32},
        {js_max_vm_mem, 128}
        ]},
 %% SASL config
 {sasl, [
    {sasl_error_logger,         {file, "/mnt/riak/log/sasl-error.log"}},
        {error_logger_mf_maxfiles, 5},
        {error_logger_mf_maxbytes, 10485760},
        {errlog_type, error},
        {error_logger_mf_dir, "/var/log/riak/sasl"}
        ]},
 %% Bitcask config
 {bitcask, [
        {max_file_size, 2147483648},
        {small_file_threshold, 10485760},
        {sync_strategy, none},
        {open_timeout, 4},
        {dead_bytes_merge_trigger, 536870912},
        {data_root, "/mnt/riak/data/bitcask"},
        {frag_merge_trigger, 60},
        {expiry_secs, -1},
        {dead_bytes_threshold, 134217728},
        {frag_threshold, 40}
        ]},
 %% Kernel config
 { kernel, [
        {inet_dist_listen_max, 7999},
        {inet_dist_listen_min, 6000}
        ]}
].


The map function:

function map_value(value, keydata, args) {
  var obj = JSON.parse(value.values[0].data);                                                                                                                                                                                                 
  var field = args[0];                                                                                                                                                                                                                        
  var bucket = args[1];                                                                                                                                                                                                                       

  return [bucket, obj[field]];                                                                                                                                                                                                                
}


{"inputs":[["purge-event","fa30556e-2b4c-4a7a-9b8f-34e058e5472e"]],"query":[{"map":{"arg":["eligible","document"],"language":"javascript","source":"function map_values(doc, keydata, args) {\n  var obj = JSON.parse(doc.values[0].data);\n \
 var field = args[0];\n  var bucket = args[1];\n\n  var bks = [];\n  var ids = obj[field];\n\n  for (var i in ids) {\n    key=ids[i];\n    bks.push([bucket, key]);\n  }\n\n  return bks;\n}\n"}}]}