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

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

Returns a stream of compressed data pages