mapreduce

tollan.utils.mapreduce(map_func, reduce_func, gen, *args, **kwargs)

Return a map and reduce generator.

Parameters

map_funccallable

The map function.

reduce_funccallable

The reduce_function.

gengenerator or iterator

The inputs.

*args, **kwargs

Passed to the functools.reduce function.

Returns

generator

The map-reduce generator.