Struct datafusion::datasource::listing::ListingTableConfig

pub struct ListingTableConfig {
    pub object_store: Arc<dyn ObjectStore>,
    pub table_path: String,
    pub file_schema: Option<SchemaRef>,
    pub options: Option<ListingOptions>,
}

Configuration for creating a ‘ListingTable’

Fields

object_store: Arc<dyn ObjectStore>

ObjectStore that contains the files for the ListingTable.

table_path: String

Path on the ObjectStore for creating ListingTable.

file_schema: Option<SchemaRef>

Optional SchemaRef for the to be created ListingTable.

options: Option<ListingOptions>

Optional ListingOptions for the to be created ListingTable.

Implementations

impl ListingTableConfig

pub fn new(
    object_store: Arc<dyn ObjectStore>,
    table_path: impl Into<String>
) -> Self

Creates new ListingTableConfig. The SchemaRef and ListingOptions are inferred based on the suffix of the provided table_path.

pub fn with_schema(self, schema: SchemaRef) -> Self

Add schema to ListingTableConfig

pub fn with_listing_options(self, listing_options: ListingOptions) -> Self

Add listing_options to ListingTableConfig

pub async fn infer_options(self) -> Result<Self>

Infer ListingOptions based on table_path suffix.

pub async fn infer_schema(self) -> Result<Self>

Infer SchemaRef based on table_path suffix. Requires self.options to be set prior to using.

pub async fn infer(self) -> Result<Self>

Convenience wrapper for calling infer_options and infer_schema