MapReduce riak.add('tweets'). map({language: 'erlang', module: 'riak_kv_mapreduce', function: 'map_object_value'}).run()