Struct CsvBatchSourceFactory 

pub struct CsvBatchSourceFactory { /* private fields */ }

Bounded CSV streaming source factory. Re-consumable bounded CSV source factory.

Implementations

impl CsvBatchSourceFactory

pub fn new(path: impl AsRef<Path>, options: CsvReadOptions) -> Self

Construct a factory for a CSV path and read options.

Trait Implementations

impl BatchSourceFactory for CsvBatchSourceFactory

fn source_name(&self) -> &'static str

Stable source identifier for diagnostics.

fn schema(&self) -> Result<SchemaRef>

Return the source schema known before the source produces batches.

fn source_limits(&self) -> Vec<SourceLimit>

Return static capability limitations visible before opening the source.

fn open(&self, context: BatchOpenContext) -> Result<Box<dyn BatchSource>>

Open an independently owned source cursor.

impl Clone for CsvBatchSourceFactory

fn clone(&self) -> CsvBatchSourceFactory

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CsvBatchSourceFactory

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

Formats the value using the given formatter.