Module Map_reduce_function.Worker
type t
type param_type
= Param.t
type run_input_type
=[
|
`Map of Input.t
|
`Combine of Accum.t * Accum.t
|
`Map_right_combine of Accum.t * Input.t
]
type run_output_type
= Accum.t
val spawn_config_exn : Config.t -> param_type -> t list Async.Deferred.t
val run_exn : t -> run_input_type -> run_output_type Async.Deferred.t
val shutdown_exn : t -> unit Async.Deferred.t