Struct LinesSource 

pub struct LinesSource<R: BufRead> { /* private fields */ }

A line-delimited reader as a source.

Implementations

impl<R: BufRead> LinesSource<R>

pub fn new(reader: R, format: LineFormat) -> LinesSource<R>

pub fn limits(self, limits: Limits) -> Self

pub fn abort(self, abort: AbortFlag) -> Self

pub fn metrics(self, metrics: Arc<Metrics>) -> Self

pub fn chunk_bytes(self, bytes: usize) -> Self

The CSV chunk size; a chunk closes at the first record boundary at or past it. Zero closes a chunk at every record.

pub fn run_owned<S: Sink + Send + 'static>( self, sink: S, ) -> (Result<Flow, Fail>, S)

Run with an owned sink: JSON Lines through the rule-event adapter (lexemes kept), CSV through the walk. The sink comes back.

pub fn run_boxed( self, sink: Box<dyn Sink + Send>, ) -> (Result<Flow, Fail>, Box<dyn Sink + Send>)

LinesSource::run_owned for a boxed sink.

Trait Implementations

impl<R: BufRead> Source for LinesSource<R>

fn run(self, sink: &mut dyn Sink) -> Result<Flow, Fail>

Both formats through the walk; JSON Lines numbers carry no lexeme on this path (see LinesSource::run_owned).