/// Convert the table specified in this chunk into some number of
/// record batches, appended to dst
Convert the table specified in this chunk into some number of
record batches, appended to dst
Convert the table specified in this chunk into some number of record batches appended to dst
pub fn to_arrow(&self, selection: Selection<'_>) -> Result<RecordBatch> {
        let schema = self.schema(selection)?;
        let columns = schema
            .iter()
            .map(|(_, field)| {
                let column = self
                    .columns
                    .get(field.name())
                    .expect("schema contains non-existent column");
                column.to_arrow().context(ColumnError {
                    column: field.name(),
                })
            })
            .collect::<Result<Vec<_>>>()?;
        RecordBatch::try_new(schema.into(), columns).context(ArrowError {})
    }
pub fn to_arrow ( & self , selection : Selection < ' _ > ) -> Result < RecordBatch > { let schema = self . schema ( selection ) ? ; let columns = schema . iter ( ) . map ( | ( _ , field ) | { let column = self . columns . get ( field . name ( ) ) . expect ( " " ) ; column . to_arrow ( ) . context ( ColumnError { column : field . name ( ) , } ) } ) . collect :: < Result < Vec < _ > > > ( ) ? ; RecordBatch :: try_new ( schema . into ( ) , columns ) . context ( ArrowError { } ) }
Convert the table specified in this chunk into some number of
record batches, appended to dst
Convert the table specified in this chunk into some number of record batches appended to dst
&self
selection
Selection<'_>