sig
class type mapred_env =
object
method config : Mapred_config.mapred_config
method config_file : Netplex_types.config_file
method open_cluster :
Unixqueue.event_system -> Plasma_client.plasma_cluster
end
class type mapred_job_config =
object
method bigblock_size : int
method custom : string -> string
method input_dir : string
method job_id : string
method log_dir : string
method map_tasks : int
method merge_limit : int
method name : string
method output_dir : string
method partitions : int
method split_limit : int
method task_files : string list
method work_dir : string
end
class type task_info =
object
method partition : int
method req_id : int
method task_prefix : string
end
class type mapred_job =
object
method check_config :
Mapred_def.mapred_env -> Mapred_def.mapred_job_config -> unit
method custom_params : string list
method extract_key :
Mapred_def.mapred_env ->
Mapred_def.mapred_job_config -> string -> string
method map :
Mapred_def.mapred_env ->
Mapred_def.mapred_job_config ->
Mapred_def.task_info ->
Mapred_io.record_reader -> Mapred_io.record_writer -> unit
method partition_of_key :
Mapred_def.mapred_env ->
Mapred_def.mapred_job_config -> string -> int
method post_job_finish :
Mapred_def.mapred_env -> Mapred_def.mapred_job_config -> unit
method pre_job_start :
Mapred_def.mapred_env -> Mapred_def.mapred_job_config -> unit
method reduce :
Mapred_def.mapred_env ->
Mapred_def.mapred_job_config ->
Mapred_def.task_info ->
Mapred_io.record_reader -> Mapred_io.record_writer -> unit
end
end
