sig
type plan_config
val configure_plan :
?keep_temp_files:bool ->
planning_capacity:float ->
internal_suffix:string ->
output_suffix:string ->
Mapred_def.mapred_job_config ->
Mapred_config.mapred_config -> Mapred_sched.plan_config
type plan
val create_plan :
?dn_identities:string list ->
Mapred_fs.filesystem -> 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 avg_runnable : Mapred_sched.plan -> float
val avg_runqueue : Mapred_sched.plan -> float
val round_points : Mapred_sched.plan -> Mapred_tasks.task -> float
val greediness_points : Mapred_sched.plan -> Mapred_tasks.task -> float
val print_plan : Netchannels.out_obj_channel -> Mapred_sched.plan -> unit
val generate_svg : Mapred_sched.plan -> string
val task_stats : Mapred_sched.plan -> Mapred_tasks.task -> int * int
val log : int -> int
end
