Class type Mapred_io.record_writer

class type record_writer = object .. end

method pos_out : int

The ordinal number of the record that will be written next. Numbers start at 0

method bpos_out : int64

The byte position of the record that will be written next

method output_record : string -> unit

Outputs these records. The records must not contain LF chars. The length is limited to the blocksize-1.

method flush : unit -> unit

Flushes the records from the buffer to disk

method from_fd_e : Unix.file_descr -> unit Uq_engines.engine

Outputs the records coming from this file. The file is read until EOF. The pos_out number is not updated, but bpos_out is. While the engine is running output_record and flush must not be called.

The file must be line-structured. If the LF after the last line is missing it is silently added. The length of the lines is not checked except in a few situations.

One should only either use from_fd_e or output_record. When mixing both styles, it is undefined which data is read by which method.

method close_out : unit -> unit

Releases resources (e.g. closes transactions)

method abort : unit -> unit

Drops resources - intended to be used for error cleanup

method plasma_cluster : Plasma_client.plasma_cluster

The PlasmaFS cluster

This web site is published by Informatikbüro Gerd Stolpmann

Plasma	GitLab	Archive
Projects	Blog	Knowledge