Struct StorageCatalogTable 

pub struct StorageCatalogTable { /* private fields */ }

Adapter that exposes a Storage plugin as a CatalogTable.

Construction is cheap — the schema is supplied by the caller so the adapter doesn’t need an async I/O to satisfy CatalogTable::schema(). If the wrapped storage’s Storage::schema yields a SchemaRef, callers can await it during plugin registration and feed it here.

Implementations

impl StorageCatalogTable

pub fn new(storage: Arc<dyn Storage>, table: String, schema: SchemaRef) -> Self

Build a new adapter over storage exposing rows from table with the supplied schema.

pub fn storage(&self) -> &Arc<dyn Storage>

Reference to the wrapped storage (useful in tests).

pub fn table(&self) -> &str

Name of the underlying table.

Trait Implementations

impl CatalogTable for StorageCatalogTable

fn schema(&self) -> SchemaRef

Schema of rows this table produces.

fn scan( &self, projection: Option<&[usize]>, filters: &[Expr], limit: Option<usize>, ) -> Result<SendableRecordBatchStream, FnError>

Stream rows matching the optional projection, filters, and limit.

fn statistics(&self) -> Option<Statistics>

Cardinality / size statistics, if known.

impl Debug for StorageCatalogTable

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

Formats the value using the given formatter.