Skip to main content

batches_to_flight_data

Function batches_to_flight_data 

Source
pub fn batches_to_flight_data<'a>(
    schema: &Schema,
    batches: impl IntoIterator<Item = &'a RecordBatch>,
) -> Result<Vec<FlightData>, ArrowError>
Expand description

Convert RecordBatches to wire protocol FlightDatas