Plasma GitLab Archive
Projects Blog Knowledge

Module Mapred_job


module Mapred_job: sig .. end
Run a map/red job

val invoke : ?catch_sigint:bool ->
?create_dirs:bool ->
Mapred_def.mapred_env ->
Mapred_job_exec.runtime_job_config ->
Mapred_def.mapred_job -> Mapred_job_exec.running_job
Prepare the job, but do not run yet any task.

  • catch_sigint: whether to catch the sigint signal (normally CTRL-C). If caught, the job is killed, and it is waiter for the termination.
  • create_dirs: whether to create the output directory, the log directory and the work directory if they do not exist yet.

val run : Mapred_job_exec.running_job -> unit
Run the tasks, and wait until the job is done
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml