Calling a named javascript function as mapper [JIRA: CLIENTS-615] #412
Description
I have a named javascript function stored in a bucket/key in Riak:
import riak
client = riak.RiakClient()
bucket = client.bucket('my_functions')
obj = riak.RiakObject(client, bucket, 'map_capacity')
obj.content_type = 'application/json'
obj.encoded_data = """function(v) {
var parsed_data = JSON.parse(v.values[0].data);
var data = {};
data[parsed_data.style] = parsed_data.capacity;
return [data];
}"""
obj.store()
The problem is when I try to call it:
mapReduce = riak.mapreduce.RiakMapReduce(client)
mapReduce.add("rooms")
mapReduce.map( "my_functions.map_capacity")
mapReduce.run()
Riak returns ReferenceError: my_functions is not defined
What 's wrong?
Thanks