2018-10-23 13:39:06 +02:00
|
|
|
(** The Farm skeleton, similar to SklMl.
|
|
|
|
|
|
|
|
|
|
The input is a stream of input data, and the output is a stream of data.
|
|
|
|
|
*)
|
|
|
|
|
|
|
|
|
|
|
2019-04-04 13:14:01 +02:00
|
|
|
val run_sequential : ('a -> 'b) -> 'a Stream.t -> 'b Stream.t
|
|
|
|
|
|
2019-04-04 09:14:15 +02:00
|
|
|
val run : ?ordered:bool -> ?comm:Mpi.communicator ->
|
|
|
|
|
f:('a -> 'b) -> 'a Stream.t -> 'b Stream.t
|
2018-10-23 13:39:06 +02:00
|
|
|
(** Run the [f] function on every process by popping elements from the
|
|
|
|
|
input stream, and putting the results on the output stream. If [ordered]
|
|
|
|
|
(the default is [ordered = true], then the order of the output is kept
|
|
|
|
|
consistent with the order of the input.
|
2019-04-04 09:14:15 +02:00
|
|
|
[comm], within MPI is a communicator. It describes a subgroup of processes.
|
2018-10-23 13:39:06 +02:00
|
|
|
*)
|
|
|
|
|
|
|
|
|
|
|
