pub async fn get_page_stream<RR>(
column_metadata: &'a ColumnChunkMetaData,
reader: &'a mut RR,
scratch: Vec<u8, Global>,
pages_filter: Arc<dyn Fn(&Descriptor, &DataPageHeader) + Sync + Send + 'static>,
max_header_size: usize
) -> Result<impl Stream<Item = Result<CompressedPage, Error>> + 'a, Error> where
RR: AsyncRead + Unpin + Send + AsyncSeek,
Available on crate feature
io_parquet
only.Expand description
Returns a stream of compressed data pages