Skip to main content

SchemaMapper

datafusion::datasource::schema_adapter

Trait SchemaMapper 

Source 
pub trait SchemaMapper:
    Debug
    + Send
    + Sync {
    // Required methods
    fn map_batch(
        &self,
        batch: RecordBatch,
    ) -> Result<RecordBatch, DataFusionError>;
    fn map_column_statistics(
        &self,
        file_col_statistics: &[ColumnStatistics],
    ) -> Result<Vec<ColumnStatistics>, DataFusionError>;
}
👎Deprecated since 52.0.0:

SchemaMapper has been removed. Use PhysicalExprAdapterFactory instead. See upgrading.md for more details.

Expand description

Deprecated: Maps columns from a specific file schema to the table schema.

This trait has been removed. Use PhysicalExprAdapterFactory instead. See upgrading.md for more details.

Required Methods§

Source

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

👎Deprecated since 52.0.0:

SchemaMapper has been removed. Use PhysicalExprAdapterFactory instead. See upgrading.md for more details.

Adapts a RecordBatch to match the table_schema.

Source

fn map_column_statistics( &self, file_col_statistics: &[ColumnStatistics], ) -> Result<Vec<ColumnStatistics>, DataFusionError>

👎Deprecated since 52.0.0:

SchemaMapper has been removed. Use PhysicalExprAdapterFactory instead. See upgrading.md for more details.

Adapts file-level column Statistics to match the table_schema.

Implementors§