Plasma GitLab Archive
Projects Blog Knowledge

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 :
    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 :
    Plasma_client.plasma_cluster ->
    Mapred_io.record_config -> string -> Mapred_io.record_writer
  val write_multiple :
    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
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml