Struct ParxBundleReader 

pub struct ParxBundleReader { /* private fields */ }

Reader for PARX bundle files.

Provides access to all cached footers in the bundle.

Implementations

impl ParxBundleReader

pub fn open(data: Bytes) -> Result<Self>

Open a bundle from bytes.

Errors

Returns error if file is invalid or corrupted.

Panics

Panics if file size is less than minimum header size.

pub const fn header(&self) -> &BundleHeader

Get the bundle header.

pub fn entry_count(&self) -> usize

Get the number of entries in the bundle.

pub const fn created_at_ms(&self) -> u64

Get the creation timestamp in milliseconds.

pub fn contains(&self, parquet_path: &str) -> bool

Check if a parquet path exists in the bundle.

pub fn parquet_paths(&self) -> Vec<&str>

Get the list of parquet paths in this bundle.

pub fn get_footer(&self, parquet_path: &str) -> Option<&[u8]>

Get footer bytes for a specific parquet file.

pub fn get_source_size(&self, parquet_path: &str) -> Option<u64>

Get source size for a specific parquet file.

pub fn validate_source_size(&self, parquet_path: &str, actual_size: u64) -> bool

Validate that a parquet file matches the expected size.

pub fn get_entry(&self, parquet_path: &str) -> Option<BundleEntryRef<'_>>

Get a full entry reference for a parquet file.

pub fn iter_entries(&self) -> impl Iterator<Item = BundleEntryRef<'_>>

Iterate over all entries in the bundle.

pub fn validate_all(&self) -> Result<()>

Validate all entry checksums.

Errors

Returns error if any checksum fails or bounds are invalid.

Trait Implementations

impl Clone for ParxBundleReader

fn clone(&self) -> ParxBundleReader

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ParxBundleReader

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.