Plasma GitLab Archive
Projects Blog Knowledge

sig
  class type mapred_env =
    object
      method arguments : string array
      method config_file : Netplex_types.config_file
      method open_cluster :
        Unixqueue.event_system -> Plasma_client.plasma_cluster
    end
  class type mapred_job =
    object
      method check_config : Mapred_def.mapred_env -> unit
      method extract_key : Mapred_def.mapred_env -> string -> string
      method input_dir : string
      method map :
        Mapred_def.mapred_env ->
        int -> Mapred_io.record_reader -> Mapred_io.record_writer -> unit
      method map_tasks : int
      method merge_limit : int
      method name : string
      method output_dir : string
      method partition_of_key : Mapred_def.mapred_env -> string -> int
      method partitions : int
      method reduce :
        Mapred_def.mapred_env ->
        int -> Mapred_io.record_reader -> Mapred_io.record_writer -> unit
      method sort_limit : int64
      method split_limit : int
      method work_dir : string
    end
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml