sig
type plan_config
val configure_plan :
?keep_temp_files:bool ->
Mapred_def.mapred_job_config ->
Mapred_config.mapred_config -> Mapred_sched.plan_config
type plan
val create_plan :
Plasma_client.plasma_cluster ->
Mapred_sched.plan_config -> Mapred_sched.plan
val bigblock_size : Mapred_sched.plan -> int
val add_inputs : Mapred_sched.plan -> unit
val add_map_output :
Mapred_sched.plan ->
int ->
(Mapred_tasks.file_tag * Mapred_tasks.file) list ->
Unix.inet_addr -> unit
val plan_complete : Mapred_sched.plan -> bool
val complete_inputs : Mapred_sched.plan -> unit
val executable_tasks : Mapred_sched.plan -> Mapred_tasks.task list
val hosts : Mapred_sched.plan -> (string * Unix.inet_addr) list
val mark_as_finished : Mapred_sched.plan -> Mapred_tasks.task -> unit
val mark_as_started :
Mapred_sched.plan ->
Mapred_tasks.task -> Unix.inet_addr -> int -> bool -> unit
val remove_marks : Mapred_sched.plan -> Mapred_tasks.task -> unit
val task_depends_on_list :
Mapred_sched.plan -> Mapred_tasks.task -> Mapred_tasks.task list
val plan_finished : Mapred_sched.plan -> bool
val n_running : Mapred_sched.plan -> int
val n_finished : Mapred_sched.plan -> int
val n_total : Mapred_sched.plan -> int
val avg_running : Mapred_sched.plan -> float
val cluster : Mapred_sched.plan -> Plasma_client.plasma_cluster
val print_plan : Mapred_sched.plan -> unit
val generate_svg : Mapred_sched.plan -> string
val task_stats : Mapred_sched.plan -> Mapred_tasks.task -> int * int
end
