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 ->
?pre_sort_algo:string ->
?keep_temp_files:bool ->
?report:bool ->
?report_to:Netchannels.out_obj_channel ->
Mapred_job_config.m_job_config -> Mapred_job_exec.runtime_job_config
val create_runtime_job_config_from_mapred_config :
?dump_plan_when_complete:bool ->
?dump_plan_as_svg:string ->
?simulate:bool ->
?pre_sort_algo:string ->
?keep_temp_files:bool ->
?report:bool ->
?report_to:Netchannels.out_obj_channel ->
Mapred_job_config.m_job_config ->
Mapred_config.mapred_config -> Mapred_job_exec.runtime_job_config
type machine_params
val investigate_machines :
Mapred_config.mapred_config ->
string -> string -> Mapred_job_exec.machine_params
val planning_capacity : Mapred_job_exec.machine_params -> float
type running_job
val start :
Unixqueue.event_system ->
Mapred_sched.plan ->
Mapred_def.mapred_job ->
Mapred_job_exec.runtime_job_config ->
Mapred_job_exec.machine_params ->
Mapred_taskfiles.taskfile_manager ->
Mapred_def.mapred_env ->
int ->
(Mapred_job_exec.running_job -> unit) -> 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
val event_system : Mapred_job_exec.running_job -> Unixqueue.event_system
val stats : Mapred_job_exec.running_job -> Mapred_stats.stats
val get_simulate : Mapred_job_exec.runtime_job_config -> bool
val get_report : Mapred_job_exec.runtime_job_config -> bool
val get_report_to :
Mapred_job_exec.runtime_job_config -> Netchannels.out_obj_channel
val get_dump_plan_when_complete :
Mapred_job_exec.runtime_job_config -> bool
val get_keep_temp_files : Mapred_job_exec.runtime_job_config -> bool
val get_job_config :
Mapred_job_exec.runtime_job_config -> Mapred_job_config.m_job_config
val get_rjc :
Mapred_job_exec.running_job -> Mapred_job_exec.runtime_job_config
val get_job : Mapred_job_exec.running_job -> Mapred_def.mapred_job
val get_tm :
Mapred_job_exec.running_job -> Mapred_taskfiles.taskfile_manager
val get_plan : Mapred_job_exec.running_job -> Mapred_sched.plan
val get_env : Mapred_job_exec.running_job -> Mapred_def.mapred_env
val message_rjc : Mapred_job_exec.runtime_job_config -> string -> unit
val message : Mapred_job_exec.running_job -> string -> unit
end
