polars_parquet/parquet/read/page/
mod.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
mod reader;
#[cfg(feature = "async")]
mod stream;

pub use reader::{PageMetaData, PageReader};

use crate::parquet::error::ParquetError;
use crate::parquet::page::CompressedPage;

pub trait PageIterator: Iterator<Item = Result<CompressedPage, ParquetError>> {
    fn swap_buffer(&mut self, buffer: &mut Vec<u8>);
}

#[cfg(feature = "async")]
#[cfg_attr(docsrs, doc(cfg(feature = "async")))]
pub use stream::{get_page_stream, get_page_stream_from_column_start};