MapReduce (map_reduce v0.1.0) View Source

Link to this section Summary

Functions

assign_jobs(partitions, worker_pids, arg)

get_hash_for(partition)

solve(collection, map_lambda, reduce_lambda)

solve(collection, map_lambda, reduce_lambda, process_count)

Link to this section Functions

Link to this function

assign_jobs(partitions, worker_pids, arg)

View Source

Link to this function

get_hash_for(partition)

View Source

Link to this function

solve(collection, map_lambda, reduce_lambda)

View Source

Link to this function

solve(collection, map_lambda, reduce_lambda, process_count)

View Source