pub async fn _get_page_stream<RR>(
    column_metadata: &'a ColumnChunkMetaData,
    reader: &'a mut RR,
    buffer: Vec<u8, Global>,
    pages_filter: Arc<dyn Fn(&ColumnDescriptor, &DataPageHeader) + Send + Sync + 'static>
) -> Result<impl Stream<Item = Result<CompressedDataPage, ParquetError>> + 'a, ParquetError> where
    RR: AsyncRead + Unpin + Send + AsyncSeek
Expand description

Returns a stream of compressed data pages