Struct FixReader 

pub struct FixReader { /* private fields */ }

Reads a FIX log a piece at a time.

Implementations

impl FixReader

pub fn new(layers: Layers) -> Self

pub fn stats(&self) -> &Stats

pub fn layers(&self) -> &Layers

pub fn push(&mut self, bytes: &[u8])

Read bytes, the next piece of the file.

pub fn take_batch(&mut self) -> PolarsResult<Option<DataFrame>>

A full batch, once one is held: BATCH_ROWS rows, or BATCH_TEXT of text.

pub fn finish(&mut self) -> PolarsResult<DataFrame>

The end of the file: what is left, and the rows not yet taken.

pub fn tag_names(&self) -> Vec<(u32, String, usize)>

Each tag and the names the dictionaries gave it, each with the dictionary’s index in Self::layers.

pub fn column_names(&self) -> Vec<(u32, String)>

Each tag’s column name: the name every dictionary that applied gave it, or its number when none did, when they disagree, or when the name is taken.

pub fn finished(&self, batch: DataFrame) -> PolarsResult<DataFrame>

batch, the last, which has every column, as the dataset shows it: for checks.

pub fn finish_frame(&self, lf: LazyFrame) -> LazyFrame

The segments’ columns renamed, typed and, for those that never held a value, dropped.

Trait Implementations

impl Debug for FixReader

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.