Struct SeriesScanNode 

pub struct SeriesScanNode { /* private fields */ }

Implementations

impl SeriesScanNode

pub fn new( series: ResolvedSeries, key_range_start: Option<u64>, key_range_end: Option<u64>, variant_tag: Option<u8>, context: Arc<QueryContext>, ) -> Result<Self>

Trait Implementations

impl QueryNode for SeriesScanNode

fn initialize<'a>( &mut self, _rx: &mut Transaction<'a>, _ctx: &QueryContext, ) -> Result<()>

Initialize the operator with execution context Called once before iteration begins

fn next<'a>( &mut self, rx: &mut Transaction<'a>, _ctx: &mut QueryContext, ) -> Result<Option<Columns>>

Get the next batch of results (volcano iterator pattern) Returns None when exhausted

fn headers(&self) -> Option<ColumnHeaders>

Get the headers of columns this node produces

fn set_scan_limit(&mut self, limit: usize)

Hint the maximum number of rows this scan needs to produce. Scan operators override this to cap their batch size. Non-scan operators ignore it (default no-op).

fn next_lazy<'a>( &mut self, _rx: &mut Transaction<'a>, _ctx: &mut QueryContext, ) -> Result<Option<LazyBatch>>

Get the next batch as a LazyBatch for deferred materialization Returns None if this node doesn’t support lazy evaluation or is exhausted Default implementation returns None (falls back to materialized evaluation)