Struct ParquetTickScan 

pub struct ParquetTickScan { /* private fields */ }

An immutable description of bounded tick partitions.

Implementations

impl ParquetTickScan

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

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

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

where F: FnMut() -> bool,

Describe tick partitions with cooperative cancellation.

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

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

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

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

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

where F: FnMut() -> bool,

Find the latest valid quote inside the inclusive scan bounds.

pub fn latest_valid_tick_before_cancellable<F>( &self, before: NaiveDateTime, is_cancelled: F, ) -> Result<Option<ParquetScannedRow<Tick>>>

where F: FnMut() -> bool,

Find the latest valid quote strictly before before and inside the scan bounds.

Trait Implementations

impl Clone for ParquetTickScan

fn clone(&self) -> ParquetTickScan

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParquetTickScan

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

Formats the value using the given formatter.