Class type Mapred_io.record_reader

class type record_reader = object .. end

method pos_in : int

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

method input_record : unit -> string

Reads one record, and advances the cursor. May raise End_of_file

method peek_record : unit -> string

Reads the record, but does not advance the cursor, i.e. the next peek_record or input_record will read the line again. May raise End_of_file.

method close_in : unit -> unit

Releases resources (e.g. closes transactions)

method abort : unit -> unit

Drops resources - intended to be used for error cleanup

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

to_fd_e esys fd: The remaining records are written to fd. The position pos_in is not updated. The length of the records is not checked except for a few records that are crucial for interpreting the boundaries of the bigblocks.

While the engine is running the other method must not be called.

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