pub fn merge_record_batch_schemas(batches: &[Arc<RecordBatch>]) -> Arc<Schema> {
    let mut merger = SchemaMerger::new();
    for batch in batches {
        let schema = Schema::try_from(batch.schema()).expect("Schema conversion error");
        merger = merger.merge(&schema).expect("schemas compatible");
    }
    Arc::new(merger.build())
}
// todo: move this function to a more appropriate crate
/// Return the merged schema for RecordBatches
///
/// This is infallable because the schemas of chunks within a
/// partition are assumed to be compatible because that schema was
/// enforced as part of writing into the partition
move this function to a more appropriate crate
Return the merged schema for RecordBatches

This is infallable because the schemas of chunks within a
partition are assumed to be compatible because that schema was
enforced as part of writing into the partition
move this function to a more appropriate crate Return the merged schema for RecordBatches This is infallable because the schemas of chunks within a partition are assumed to be compatible because that schema was enforced as part of writing into the partition
pub fn merge_record_batch_schemas(batches: &[Arc<RecordBatch>]) -> Arc<Schema> {
    let mut merger = SchemaMerger::new();
    for batch in batches {
        let schema = Schema::try_from(batch.schema()).expect("Schema conversion error");
        merger = merger.merge(&schema).expect("schemas compatible");
    }
    Arc::new(merger.build())
}
pub fn merge_record_batch_schemas ( batches : & [ Arc < RecordBatch > ] ) -> Arc < Schema > { let mut merger = SchemaMerger :: new ( ) ; for batch in batches { let schema = Schema :: try_from ( batch . schema ( ) ) . expect ( " " ) ; merger = merger . merge ( & schema ) . expect ( " " ) ; } Arc :: new ( merger . build ( ) ) }
todo: move this function to a more appropriate crate
Return the merged schema for RecordBatches
todo : move this function to a more appropriate crate Return the merged schema for RecordBatches
batches
&[Arc<RecordBatch>]
batches
&[Arc<RecordBatch>]