Struct ScanBuilder 

pub struct ScanBuilder<A = ArrayRef> { /* private fields */ }

Builds a projection scan on the planner-driven V2 executor.

This builder reads the file’s layout and segments directly. Unsupported layouts return an error when the stream is polled. Filters and row limits are not supported.

Implementations

impl ScanBuilder<ArrayRef>

pub fn new(session: VortexSession, file: ScanFile) -> Self

Creates a V2 scan over the file’s layout and segment source.

pub fn into_record_batch_stream( self, schema: SchemaRef, ) -> VortexResult<impl Stream<Item = Result<RecordBatch, ArrowError>> + Send + 'static>

Converts each output batch to Arrow on the split’s task.

impl<A: 'static + Send> ScanBuilder<A>

pub fn dtype(&self) -> &DType

The output dtype after projection, before any output mapping.

pub fn with_projection(self, projection: BoundExpression) -> Self

Sets a projection bound against the file’s dtype.

pub fn with_ordered(self, ordered: bool) -> Self

Configures whether batches are yielded in file order.

pub fn with_row_range(self, row_range: Range<u64>) -> Self

Restricts scanning to a contiguous file-local row range.

pub fn with_selection(self, selection: Selection) -> Self

Applies a row selection within the scan’s row range.

pub fn with_row_indices(self, row_indices: StrictSortedBuffer<u64>) -> Self

Selects rows by strictly sorted file-local indices.

pub fn with_row_offset(self, row_offset: u64) -> Self

Sets the root row offset used by row-index expressions.

pub fn with_concurrency(self, concurrency: usize) -> Self

Sets the number of active splits per worker thread. Must be greater than zero.

pub fn into_stream(self) -> VortexResult<BoxStream<'static, VortexResult<A>>>

Runs the scan on the session’s runtime, preparing it on the first poll. Preparation errors are returned as stream items.