String code = @"
local function reducer(val1,val2)
return val1 + val2
end
function sum_single_bin(stream,name)
local function mapper(rec)
return rec[name]
end
return stream : map(mapper) : reduce(reducer)
end
";
client.RegisterUdfString(null, code, "mysum.lua", Language.LUA);
This asynchronous server call will return before command is complete. The user can optionally wait for command completion by using the returned RegisterTask instance.
public RegisterTask RegisterUdfString(
Policy policy,
string code,
string serverPath,
Language language
)
AerospikeException | if register fails |