datafusion_datasource::schema_adapter

Trait SchemaMapper

Source 
pub trait SchemaMapper:
    Debug
    + Send
    + Sync {
    // Required method
    fn map_batch(&self, batch: RecordBatch) -> Result<RecordBatch>;
}
Expand description

Maps, columns from a specific file schema to the table schema.

See DefaultSchemaAdapterFactory for more details and examples.

Required Methods§

Source

fn map_batch(&self, batch: RecordBatch) -> Result<RecordBatch>

Adapts a RecordBatch to match the table_schema

Implementors§