sig
type config
val create_config :
?name:string ->
?task_files:string list ->
?bigblock_size:int ->
?map_tasks:int ->
?merge_limit:int ->
?split_limit:int ->
?partitions:int ->
?enhanced_mapping:int ->
?phases:Mapred_def.phases ->
?report:bool ->
?report_to:Netchannels.out_obj_channel ->
?keep_temp_files:bool ->
Mapred_def.mapred_env -> Mapred_toolkit.DSeq.config
val get_rc : Mapred_toolkit.DSeq.config -> Mapred_io.record_config
type 'a result
val get_result : 'a Mapred_toolkit.DSeq.result -> 'a
val stats : 'a Mapred_toolkit.DSeq.result -> Mapred_stats.stats
val job_id : Mapred_toolkit.DSeq.config -> string
class type mapred_info =
object
method mapred_env : Mapred_def.mapred_env
method mapred_job_config : Mapred_def.mapred_job_config
end
val mapl :
(Mapred_toolkit.DSeq.mapred_info -> 'a -> 'b list) Mapred_rfun.rfun ->
'a Mapred_toolkit.Place.t ->
'b Mapred_toolkit.Place.t ->
Mapred_toolkit.DSeq.config ->
('b, [ `W ]) Mapred_toolkit.Seq.seq list Mapred_toolkit.DSeq.result
val mapl_sort_fold :
mapl:(Mapred_toolkit.DSeq.mapred_info -> 'a -> 'b list) Mapred_rfun.rfun ->
hash:(Mapred_toolkit.DSeq.mapred_info -> 'b -> int) Mapred_rfun.rfun ->
cmp:(Mapred_toolkit.DSeq.mapred_info -> 'b -> 'b -> int) Mapred_rfun.rfun ->
initfold:(Mapred_toolkit.DSeq.mapred_info -> int -> 'c) Mapred_rfun.rfun ->
fold:(Mapred_toolkit.DSeq.mapred_info -> 'c -> 'b -> 'c * 'd list)
Mapred_rfun.rfun ->
?finfold:(Mapred_toolkit.DSeq.mapred_info -> 'c -> 'd list)
Mapred_rfun.rfun ->
partition_of:(Mapred_toolkit.DSeq.mapred_info -> 'b -> int)
Mapred_rfun.rfun ->
?initcombine:(Mapred_toolkit.DSeq.mapred_info -> 'e) Mapred_rfun.rfun ->
?combine:(Mapred_toolkit.DSeq.mapred_info -> 'e -> 'b -> 'e * 'b list)
Mapred_rfun.rfun ->
?fincombine:(Mapred_toolkit.DSeq.mapred_info -> 'e -> 'b list)
Mapred_rfun.rfun ->
'a Mapred_toolkit.Place.t ->
'd Mapred_toolkit.Place.t ->
Mapred_toolkit.DSeq.config ->
'b Mapred_toolkit.Place.codec ->
('d, [ `W ]) Mapred_toolkit.Seq.seq list Mapred_toolkit.DSeq.result
end
