pub async fn collect_query(mut query_results: PerformQuery) -> Vec<RecordBatch> {
    let mut batches = vec![];
    while let Some(data) = query_results.next().await.unwrap() {
        batches.push(data);
    }
    batches
}
/// Collect the results of a query into a vector of record batches
Collect the results of a query into a vector of record batches
Collect the results of a query into a vector of record batches
pub async fn collect_query(mut query_results: PerformQuery) -> Vec<RecordBatch> {
    let mut batches = vec![];
    while let Some(data) = query_results.next().await.unwrap() {
        batches.push(data);
    }
    batches
}
pub async fn collect_query ( mut query_results : PerformQuery ) -> Vec < RecordBatch > { let mut batches = vec ! [ ] ; while let Some ( data ) = query_results . next ( ) . await . unwrap ( ) { batches . push ( data ) ; } batches }
Collect the results of a query into a vector of record batches
Collect the results of a query into a vector of record batches
query_results
PerformQuery
query_results
PerformQuery