Struct StreamingData 

pub(crate) struct StreamingData<'a> {
    pub(crate) data: ReadStatData,
    chunk_rows: usize,
    expected_rows: usize,
    rows_emitted: usize,
    sink: &'a mut dyn FnMut(RecordBatch) -> Result<(), ReadStatError>,
}

Callback context used by the high-level reader to rotate builders while a single ReadStat parse is in progress.

Fields

data: ReadStatData

chunk_rows: usize

expected_rows: usize

rows_emitted: usize

sink: &'a mut dyn FnMut(RecordBatch) -> Result<(), ReadStatError>

Implementations

impl StreamingData<'_>

pub(crate) fn finish_chunk(&mut self) -> Result<(), ReadStatError>

pub(crate) fn row_complete(&mut self) -> Result<(), ReadStatError>