/// collect data for the given chunk
collect data for the given chunk
collect data for the given chunk
pub async fn collect_read_filter(chunk: &dyn QueryChunk) -> Vec<RecordBatch> {
    chunk
        .read_filter(
            IOxSessionContext::default(),
            &Default::default(),
            Selection::All,
        )
        .unwrap()
        .collect::<Vec<_>>()
        .await
        .into_iter()
        .map(Result::unwrap)
        .collect()
}
pub async fn collect_read_filter ( chunk : & dyn QueryChunk ) -> Vec < RecordBatch > { chunk . read_filter ( IOxSessionContext :: default ( ) , & Default :: default ( ) , Selection :: All , ) . unwrap ( ) . collect :: < Vec < _ > > ( ) . await . into_iter ( ) . map ( Result :: unwrap ) . collect ( ) }
collect data for the given chunk
collect data for the given chunk
chunk
&dyn QueryChunk