Plasma GitLab Archive
Projects Blog Knowledge

Plasma Project:
Home 
Manual 
FAQ 
Slides 
Perf 
Releases 
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
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml