Struct ReadNodeProps 

pub struct ReadNodeProps<C: PipelineOperator> { /* private fields */ }

Appends property columns to a chunk for live (selection-vector-passing) rows only.

Reads one batch of node properties per next_chunk() call using NodeStore::batch_read_node_props_nullable, building a NullBitmap from the Option<u64> results and appending one ColumnVector per col_id to the chunk.

Rows that are already dead (not in the selection vector) are never read — this enforces the late-materialization principle: no I/O for filtered rows.

Implementations

impl<C: PipelineOperator> ReadNodeProps<C>

pub fn new( child: C, store: Arc<NodeStore>, label_id: u32, slot_col_id: u32, col_ids: Vec<u32>, ) -> Self

Create a ReadNodeProps operator.

• child — upstream operator yielding chunks that contain a slot column.
• store — shared reference to the node store.
• label_id — label whose column files to read.
• slot_col_id — column ID in the child chunk that holds slot numbers.
• col_ids — property column IDs to append to each output chunk.

Trait Implementations

impl<C: PipelineOperator> PipelineOperator for ReadNodeProps<C>

fn next_chunk(&mut self) -> Result<Option<DataChunk>>

Pull the next chunk of output. Returns None when exhausted.

fn cardinality_hint(&self) -> Option<usize>

Estimated output cardinality (rows) hint for pre-allocation.