arrow_integration_testing::flight_client_scenarios::integration_test

Function send_batch

Source 
async fn send_batch(
    upload_tx: &mut Sender<FlightData>,
    metadata: &[u8],
    batch: &RecordBatch,
    options: &IpcWriteOptions,
    dictionary_tracker: &mut DictionaryTracker,
) -> Result<(), Box<dyn Error + Send + Sync + 'static>>