Function arrow2::io::parquet::read::get_page_stream

pub async fn get_page_stream<RR, 'a>(
    column_metadata: &'a ColumnChunkMetaData,
    reader: &'a mut RR,
    scratch: Vec<u8, Global>,
    pages_filter: Arc<dyn Fn(&Descriptor, &DataPageHeader) -> bool + Send + Sync + 'static>,
    max_page_size: usize
) -> impl Future<Output = Result<impl Stream<Item = Result<CompressedPage, Error>> + 'a, Error>>where
    RR: AsyncRead + Unpin + Send + AsyncSeek,

Available on crate feature io_parquet only.

Returns a stream of compressed data pages