sig
class type record_reader =
object
method abort : unit -> unit
method close_in : unit -> unit
method input_record : unit -> string
method peek_record : unit -> string
method pos_in : int
end
class type record_writer =
object
method abort : unit -> unit
method bpos_out : int64
method close_out : unit -> unit
method flush : unit -> unit
method output_record : string -> unit
method pos_out : int
end
val read_file :
Plasma_client.plasma_cluster ->
string -> int64 -> int64 -> Mapred_io.record_reader
val read_multiple :
(unit -> Mapred_io.record_reader) list -> Mapred_io.record_reader
val write_file :
Plasma_client.plasma_cluster -> string -> Mapred_io.record_writer
val write_multiple :
Plasma_client.plasma_cluster ->
string -> int64 -> (string -> int -> string) -> Mapred_io.record_writer
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
