Struct ParquetBatchSourceFactory 

pub struct ParquetBatchSourceFactory { /* private fields */ }

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

Implementations

impl ParquetBatchSourceFactory

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

Construct a factory for a Parquet path and read options.

Trait Implementations

impl BatchSourceFactory for ParquetBatchSourceFactory

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 ParquetBatchSourceFactory

fn clone(&self) -> ParquetBatchSourceFactory

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParquetBatchSourceFactory

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

Formats the value using the given formatter.