MapReduce (map_reduce v0.2.0) View Source

Link to this section Summary

Functions

schedule_jobs(partitions, workers_count, arg)

solve(collection, map_lambda, reduce_lambda)

solve(collection, map_lambda, reduce_lambda, processes_count)

Link to this section Functions

Link to this function

schedule_jobs(partitions, workers_count, arg)

View Source

Link to this function

solve(collection, map_lambda, reduce_lambda)

View Source

Link to this function

solve(collection, map_lambda, reduce_lambda, processes_count)

View Source