async fn write_arrow_bytes( recordbatches: Pin<Box<dyn RecordBatchStream + Send>>, schema: &Arc<Schema>, compression: Option<CompressionType>, ) -> Result<Vec<u8>, Error>