sig type input type output val compute : ThreadPoolExecutor.t -> MapReduce.S.input Stream.t -> MapReduce.S.output -> MapReduce.S.output end