Up
Module type
Map_reduce_function
Signature
module
Param
:
Core.Std.Binable
module
Accum
:
Core.Std.Binable
module
Input
:
Core.Std.Binable
module
Worker
:
Worker
with
type
param_type
=
Param.t
and
type
run_input_type
= [
| `Map
of
Input.t
| `Combine
of
Accum.t
*
Accum.t
| `Map_right_combine
of
Accum.t
*
Input.t
]
and
type
run_output_type
=
Accum.t