Struct ParquetBarScan 

pub struct ParquetBarScan { /* private fields */ }

An immutable description of bounded bar partitions.

Implementations

impl ParquetBarScan

pub fn describe( root: impl AsRef<Path>, exchange: &str, symbol: &str, timeframe: &str, bounds: ParquetScanBounds, ) -> Result<Self>

Describe bar partitions and bind each path to its current file fingerprint.

pub fn describe_cancellable<F>( root: impl AsRef<Path>, exchange: &str, symbol: &str, timeframe: &str, bounds: ParquetScanBounds, is_cancelled: F, ) -> Result<Self>

where F: FnMut() -> bool,

Describe bar partitions with cooperative cancellation.

pub fn cursor(&self) -> Result<ParquetBarCursor>

Open a cursor against the file generations bound by this description.

pub fn cursor_with_read_size( &self, rows_per_read: usize, ) -> Result<ParquetBarCursor>

Open a cursor with a maximum number of rows decoded per read.

pub fn latest_valid_bar_cancellable<F>( &self, is_cancelled: F, ) -> Result<Option<ParquetScannedRow<Bar>>>

where F: FnMut() -> bool,

Find the latest bar with a valid close inside the inclusive scan bounds.

Trait Implementations

impl Clone for ParquetBarScan

fn clone(&self) -> ParquetBarScan

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParquetBarScan

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

Formats the value using the given formatter.