Skip to main content

Module stream

Module stream 

Source
Expand description

Streaming table I/O. Table and file I/O that does not go through memory.

Client::read_table, Client::write_table and Client::read_file hold the whole thing at once, which is right for a launcher inspecting a result and wrong for anything the size of the data. The streaming forms move the same bytes without ever holding more than a buffer of them.

Both are the raw byte stream — a YSON list fragment — because that is what the other end of this project already speaks: ytsaurus_job::JobReader reads exactly this, so a table read on a laptop and a table read inside a job go through the same decoder.

Structs§

ResponseReader
A response body, arriving as it is read.

Type Aliases§

FileReader
A file’s bytes, arriving as they are read.
TableReader
A table’s rows, arriving as they are read.