pub fn new_record_batch_iter( source_conn: &SourceConn, origin_query: Option<String>, queries: &[CXQuery<String>], batch_size: usize, pre_execution_queries: Option<&[String]>, ) -> Box<dyn RecordBatchIterator>