arrow_integration_testing::flight_client_scenarios::integration_test

Function upload_data

Source 
async fn upload_data(
    client: FlightServiceClient<Channel>,
    schema: SchemaRef,
    descriptor: FlightDescriptor,
    original_data: Vec<RecordBatch>,
) -> Result<(), Box<dyn Error + Send + Sync + 'static>>