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