Up

Parameter S : Map_reduce_function_spec

Signature

module Accum : Core.Std.Binable

module Input : Core.Std.Binable

val map : Input.t -> Accum.t Async.Std.Deferred.t

val combine : Accum.t -> Accum.t -> Accum.t Async.Std.Deferred.t