module type S =sig
..end
JoinMapRed.Make
.type
init
type
input
type
output
val client : JoinHelper.configuration -> unit
client cfg
uses the cfg
to connect to the server, and registers itself
to receive computations (i.e. executions of JoinMapRed.Problem.map
).val server : JoinHelper.configuration ->
init ->
('a, input) JoinPool.Simple.enum ->
output -> output
server cfg i e z
sets up a server using the passed configuration, and
dispatches tasks to registered clients using a pool.
The result is reduce k1 v1 (reduce k2 v2 (... (reduce kn vn z)))
where:
reduce
is a shorthand for JoinMapRed.Problem.reduce
;(ki, vi)
couples are the values returned by the client agents
(outcomes of JoinMapRed.Problem.map
applications for xi
),
the vi
being combined through JoinMapRed.Problem.combine
for equal keys;xi
are the values successively returned by e
.