Plasma GitLab Archive
Projects Blog Knowledge

sig
  type plan_config
  val configure_plan :
    ?keep_temp_files:bool -> string list -> Mapred_sched.plan_config
  type plan
  val create_plan :
    Plasma_client.plasma_cluster ->
    Mapred_sched.plan_config -> Mapred_sched.plan
  val add_inputs : Mapred_sched.plan -> Mapred_def.mapred_job -> unit
  val add_map_output :
    Mapred_sched.plan ->
    Mapred_def.mapred_job ->
    Mapred_tasks.map_task -> Mapred_tasks.file list -> unit
  val plan_complete : Mapred_sched.plan -> bool
  val complete_inputs : Mapred_sched.plan -> Mapred_def.mapred_job -> 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 -> 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 cluster : Mapred_sched.plan -> Plasma_client.plasma_cluster
  val print_plan : Mapred_sched.plan -> unit
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml