sig
type runtime_job_config
val create_runtime_job_config :
?map_weight:float * float ->
?sort_weight:float * float ->
?shuffle_weight:float * float ->
?reduce_weight:float * float ->
?dump_plan_when_complete:bool ->
?shm_low:int64 ->
?shm_high:int64 ->
io_load:float ->
cpu_load:float -> unit -> Mapred_job_exec.runtime_job_config
type running_job
val start :
Unixqueue.event_system ->
Mapred_sched.plan ->
Mapred_def.mapred_job ->
Mapred_job_exec.runtime_job_config ->
string array -> int -> Mapred_job_exec.running_job
val kill : Mapred_job_exec.running_job -> unit
val cleanup : Mapred_job_exec.running_job -> unit
type status = [ `Errors of string list | `Killed | `Running | `Successful ]
val status : Mapred_job_exec.running_job -> Mapred_job_exec.status
end
