pub async fn remote_collect( options: ConnectionOptions, sql: impl Into<String>, ) -> Result<Vec<RecordBatch>>