OCaml distributed data processing