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
