Plasma GitLab Archive
Projects Blog Knowledge

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 ->
    auth_ticket:string ->
    load_limit:float ->
    Mapred_job_config.m_job_config -> Mapred_job_exec.runtime_job_config
  type running_job
  val start :
    Unixqueue.event_system ->
    Mapred_sched.plan ->
    Mapred_def.mapred_job ->
    Mapred_job_exec.runtime_job_config -> int -> 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
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml