Skip to main content

send_batch

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,
    ipc_write_context: &mut IpcWriteContext,
) -> Result<(), Box<dyn Error + Send + Sync + 'static>>