sig
type runtime_job_config
val create_runtime_job_config :
?map_weight:float * float ->
?emap_weight:float * float ->
?sort_weight:float * float ->
?shuffle_weight:float * float ->
?reduce_weight:float * float ->
?dump_plan_when_complete:bool ->
?dump_plan_as_svg:string ->
?shm_low:int64 ->
?shm_high:int64 ->
?shm_max:int64 ->
?buf_low:int64 ->
?buf_high:int64 ->
?buf_max:int64 ->
?shm_low_factor:float ->
?shm_high_factor:float ->
?shm_max_factor:float ->
?buf_low_factor:float ->
?buf_high_factor:float ->
?buf_max_factor:float ->
?simulate:bool ->
auth_ticket:string ->
load_limit:float ->
Mapred_job_config.m_job_config -> 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 -> 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
