Struct DeltaScan 

pub struct DeltaScan { /* private fields */ }

One immutable, single-use streaming Delta scan plan.

A scan cannot be cloned or converted into a stream twice.

use delta_arrow_reader::DeltaScan;

fn stream_twice(scan: DeltaScan) {
    let _ = scan.into_stream();
    let _ = scan.into_stream();
}

use delta_arrow_reader::DeltaScan;

fn clone_scan(scan: DeltaScan) {
    let _ = scan.clone();
}

Implementations

impl DeltaScan

pub fn schema(&self) -> SchemaRef

Returns a shared handle to the visible logical output schema.

pub fn partition_count(&self) -> usize

Returns the number of planned execution partitions.

pub fn into_stream(self) -> DeltaBatchStream

Converts the scan into a pull-driven Arrow batch stream.

Reads for query results begin when the stream is polled. Network warmup may already have read calibration ranges during table loading or scan building.