def reductor(result_set):
    """Do the reduce part of map/reduce and return a list of rows."""
    result_list = []
    while result_set.qsize() > 0:
        result = result_set.get()
        for row in result:
            result_list.append(row)
    return result_list