gistfile1.lua

aggregate("sum", 0, function(a, b)
    return a + b
end)

-- gather yields records
function gather(argv, yield)
    for i = 1, 100 do
        yield(i)
    end
end

-- process is called in parallel for each record yielded by gather
function process(record)
    sum(record)
end

-- summarize is called when gather returns and all records have been processed
function summarize()
    log(sum())
end