local function print_r ( t )
local print_r_cache={}
local function sub_print_r(t,indent)
if (print_r_cache[tostring(t)]) then
print(indent.."*"..tostring(t))
else
print_r_cache[tostring(t)]=true
if (type(t)=="table") then
local tLen = #t
for i = 1, tLen do
local val = t[i]
if (type(val)=="table") then
print(indent.."#["..i.."] => "..tostring(t).." {")
sub_print_r(val,indent..string.rep(" ",string.len(i)+8))
print(indent..string.rep(" ",string.len(i)+6).."}")
elseif (type(val)=="string") then
print(indent.."#["..i..'] => "'..val..'"')
else
print(indent.."#["..i.."] => "..tostring(val))
end
end
for pos,val in pairs(t) do
if type(pos) ~= "number" or math.floor(pos) ~= pos or (pos < 1 or pos > tLen) then
if (type(val)=="table") then
print(indent.."["..pos.."] => "..tostring(t).." {")
sub_print_r(val,indent..string.rep(" ",string.len(pos)+8))
print(indent..string.rep(" ",string.len(pos)+6).."}")
elseif (type(val)=="string") then
print(indent.."["..pos..'] => "'..val..'"')
else
print(indent.."["..pos.."] => "..tostring(val))
end
end
end
else
print(indent..tostring(t))
end
end
end
if (type(t)=="table") then
print(tostring(t).." {")
sub_print_r(t," ")
print("}")
else
sub_print_r(t," ")
end
print()
end
function map(vertex)
local trans = transaction();
return trans:get_vertex_metadata(VertexQuery.vertices({vertex.id}), "mapreduce_commit_test");
end
function value_to_count(value)
if value == nil then
return 0;
elseif type(value) == "table" then
if #value > 0 then
assert(value[1].value == "foo");
end
return 1;
else
return value;
end
end
function reduce(first, second)
return value_to_count(first) + value_to_count(second);
end
return { map=map, reduce=reduce }