Struct SparkSchemaAdapterFactory

pub struct SparkSchemaAdapterFactory { /* private fields */ }

An implementation of DataFusion’s SchemaAdapterFactory that uses a Spark-compatible cast implementation.

Implementations

impl SparkSchemaAdapterFactory

pub fn new(options: SparkCastOptions) -> Self

Trait Implementations

impl Clone for SparkSchemaAdapterFactory

fn clone(&self) -> SparkSchemaAdapterFactory

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SparkSchemaAdapterFactory

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

Formats the value using the given formatter.

impl SchemaAdapterFactory for SparkSchemaAdapterFactory

fn create( &self, required_schema: SchemaRef, table_schema: SchemaRef, ) -> Box<dyn SchemaAdapter>

Create a new factory for mapping batches from a file schema to a table schema.

This is a convenience for [DefaultSchemaAdapterFactory::create] with the same schema for both the projected table schema and the table schema.