Trait ReadOptions 

pub trait ReadOptions<'a> {
    // Required methods
    fn to_listing_options(
        &self,
        config: &SessionConfig,
        table_options: TableOptions,
    ) -> ListingOptions;
    fn get_resolved_schema<'life0, 'life1, 'async_trait>(
        &'life0 self,
        config: &'life1 SessionConfig,
        state: SessionState,
        table_path: ListingTableUrl,
    ) -> Pin<Box<dyn Future<Output = Result<SchemaRef>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;

    // Provided method
    fn _get_resolved_schema<'life0, 'async_trait>(
        &'a self,
        config: &'life0 SessionConfig,
        state: SessionState,
        table_path: ListingTableUrl,
        schema: Option<&'a Schema>,
    ) -> Pin<Box<dyn Future<Output = Result<SchemaRef>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'a: 'async_trait,
             'life0: 'async_trait { ... }
}

[‘ReadOptions’] is implemented by Options like [‘CsvReadOptions’] that control the reading of respective files/sources.

Required Methods

fn to_listing_options( &self, config: &SessionConfig, table_options: TableOptions, ) -> ListingOptions

Helper to convert these user facing options to ListingTable options

fn get_resolved_schema<'life0, 'life1, 'async_trait>( &'life0 self, config: &'life1 SessionConfig, state: SessionState, table_path: ListingTableUrl, ) -> Pin<Box<dyn Future<Output = Result<SchemaRef>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Infer and resolve the schema from the files/sources provided.

Provided Methods

fn _get_resolved_schema<'life0, 'async_trait>( &'a self, config: &'life0 SessionConfig, state: SessionState, table_path: ListingTableUrl, schema: Option<&'a Schema>, ) -> Pin<Box<dyn Future<Output = Result<SchemaRef>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

helper function to reduce repetitive code. Infers the schema from sources if not provided. Infinite data sources not supported through this function.

Implementors

impl ReadOptions<'_> for ArrowReadOptions<'_>

impl ReadOptions<'_> for AvroReadOptions<'_>

impl ReadOptions<'_> for CsvReadOptions<'_>

impl ReadOptions<'_> for NdJsonReadOptions<'_>

impl ReadOptions<'_> for ParquetReadOptions<'_>