Plasma GitLab Archive
Projects Blog Knowledge

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
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml