Struct ParquetTickCursor 

pub struct ParquetTickCursor { /* private fields */ }

Partition-at-a-time cursor over ascending tick rows.

Implementations

impl ParquetTickCursor

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

Open a tick cursor directly from a Parquet data root.

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

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

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

where F: FnMut() -> bool,

Open a tick cursor while checking cancellation during partition discovery.

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

where F: FnMut() -> bool,

Open a bounded tick cursor with cancellable partition discovery.

pub fn next_tick(&mut self) -> Result<Option<Tick>>

Read the next ascending tick.

pub fn next_tick_with_ordinal( &mut self, ) -> Result<Option<ParquetScannedRow<Tick>>>

Read the next ascending tick with its physical source-row ordinal.

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

where F: FnMut() -> bool,

Read the next ascending tick with cooperative cancellation.

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

where F: FnMut() -> bool,

Read the next tick and source ordinal with cooperative cancellation.

pub fn remaining_partitions(&self) -> usize

Number of date partitions still active or pending.

pub fn rows_per_read(&self) -> usize

Maximum number of rows decoded by one Parquet read.