File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 1111However, since ` @distributed ` partitions ` itrs ` evenly across nodes, some nodes
1212may be idle if the nodes are different in computational speed, or equivalently
1313if ` f ` takes different time to compute depending on the input. With the added option
14- ` pmapreduce(f, + , itrs...; algorithm = :reduction_local) ` , computations are
14+ ` pmapreduce(f, op , itrs...; algorithm = :reduction_local) ` , computations are
1515dynamically load balanced, that is, the elements in ` itrs ` are only distributed
16- to a worker which is free. The result of each computation of ` f ` are stored
16+ to a worker which is free. The result of each computation of ` f ` is stored
1717and reduced locally, until ` itrs ` is exhausted, and then sent back to the master
1818process, where the results from the nodes are further reduced, thus saving
1919communication bandwidth.
You can’t perform that action at this time.
0 commit comments