Struct NdjsonPerRowDriver 

pub struct NdjsonPerRowDriver<R> { /* private fields */ }

Forward-only per-row NDJSON reader.

Implementations

impl<R: BufRead> NdjsonPerRowDriver<R>

pub fn new(reader: R) -> Self

pub fn with_options(self, options: NdjsonOptions) -> Self

pub fn with_max_line_len(self, max_line_len: usize) -> Self

pub fn with_row_frame(self, row_frame: NdjsonRowFrame) -> Self

pub fn line_no(&self) -> u64

pub fn read_next_nonempty<'a>( &mut self, buf: &'a mut Vec<u8>, ) -> Result<Option<(u64, &'a [u8])>, RowError>

Read the next non-empty NDJSON row into buf, returning its 1-based line number. Empty and whitespace-only rows are skipped.

pub fn read_next_owned( &mut self, buf: &mut Vec<u8>, ) -> Result<Option<(u64, Vec<u8>)>, RowError>

Read the next non-empty row and transfer ownership of buf to the caller. This is the hot path used by JetroEngine NDJSON execution so the row can be parsed without an extra bytes copy.