Crate datafusion_catalog 

Interfaces and default implementations of catalogs and schemas.

Implementations

• Information schema: information_schema
• Simple memory based catalog: MemoryCatalogProviderList, MemoryCatalogProvider, MemorySchemaProvider
• Listing schema: listing_schema

Re-exports

pub use memory::MemTable;

pub use memory::MemoryCatalogProvider;

pub use memory::MemoryCatalogProviderList;

pub use memory::MemorySchemaProvider;

Modules

async 🔒

catalog 🔒

cte_worktable

CteWorkTable implementation used for recursive queries

default_table_source

Default TableSource implementation used in DataFusion physical plans

dynamic_file 🔒

information_schema

InformationSchemaProvider that implements the SQL Information Schema for DataFusion.

listing_schema

ListingSchemaProvider: SchemaProvider that scans ObjectStores for tables automatically

memory

schema 🔒

Describes the interface and built-in implementations of schemas, representing collections of named tables.

session 🔒

stream

TableProvider for stream sources, such as FIFO files

streaming

A simplified TableProvider for streaming partitioned datasets

table 🔒

view

View data source which uses a LogicalPlan as it’s input.

Structs

DynamicFileCatalog

Wrap another catalog provider list

DynamicFileSchemaProvider

Implements the DynamicFileSchemaProvider that can create tables provider from the file path.

ScanArgs

Arguments for scanning a table with TableProvider::scan_with_args.

ScanResult

Result of a table scan operation from TableProvider::scan_with_args.

TableFunction

A table that uses a function to generate data

Traits

AsyncCatalogProvider

A trait for catalog providers that must resolve schemas asynchronously

AsyncCatalogProviderList

A trait for catalog provider lists that must resolve catalogs asynchronously

AsyncSchemaProvider

A trait for schema providers that must resolve tables asynchronously

CatalogProvider

Represents a catalog, comprising a number of named schemas.

CatalogProviderList

Represent a list of named CatalogProviders.

SchemaProvider

Represents a schema, comprising a number of named tables.

Session

Interface for accessing SessionState from the catalog and data source.

TableFunctionImpl

A trait for table function implementations

TableProvider

A table which can be queried and modified.

TableProviderFactory

A factory which creates TableProviders at runtime given a URL.

UrlTableFactory

UrlTableFactory is a factory that can create a table provider from the given url.