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