sig
class type record_config =
object
method bigblock_size : int
method mr_buffer_size : int
method mr_buffer_size_tight : int
end
class type record_reader =
object
method abort : unit -> unit
method close_in : unit -> unit
method input_record : unit -> string
method input_records : string Queue.t -> unit
method peek_record : unit -> string
method plasma_cluster : Plasma_client.plasma_cluster
method pos_in : int
method to_any_e :
(Netsys_mem.memory -> int -> int -> unit Uq_engines.engine) ->
unit Uq_engines.engine
method to_fd_e : Unix.file_descr -> unit Uq_engines.engine
end
class type record_writer =
object
method abort : unit -> unit
method bpos_out : int64
method close_out : unit -> unit
method flush : unit -> unit
method from_fd_e : Unix.file_descr -> unit Uq_engines.engine
method output_record : string -> unit
method plasma_cluster : Plasma_client.plasma_cluster
method pos_out : int
end
val bigblock_size : Plasma_client.plasma_cluster -> int -> int
val read_file :
?force_bof:bool ->
?force_eof:int64 ->
?divisor:int ->
Plasma_client.plasma_cluster ->
Mapred_io.record_config ->
string -> int64 -> int64 -> Mapred_io.record_reader
type sync_readers = (unit -> Mapred_io.record_reader) list
type async_readers =
(unit -> Mapred_io.record_reader Uq_engines.engine) list
val read_multiple :
Plasma_client.plasma_cluster ->
Mapred_io.record_config ->
readers:[ `Async of Mapred_io.async_readers
| `Sync of Mapred_io.sync_readers ] ->
unit -> Mapred_io.record_reader
val write_file :
?divisor:int ->
Plasma_client.plasma_cluster ->
Mapred_io.record_config -> string -> Mapred_io.record_writer
val write_multiple :
?divisor:int ->
Plasma_client.plasma_cluster ->
Mapred_io.record_config ->
string ->
int64 ->
create_sync:(string -> int -> string) ->
?create_async:(string -> int -> string Uq_engines.engine) ->
unit -> Mapred_io.record_writer
val create_file_e :
?repl:int ->
Plasma_client.plasma_cluster -> string -> unit Uq_engines.engine
val create_file :
?repl:int -> Plasma_client.plasma_cluster -> string -> unit
val delete_file : Plasma_client.plasma_cluster -> string -> unit
val file_blocks : Plasma_client.plasma_cluster -> string -> int64
end
