Skip to main content

DataSourceScan

Trait DataSourceScan 

Source
pub trait DataSourceScan: 'static + Send {
    // Required methods
    fn dtype(&self) -> &DType;
    fn partition_count(&self) -> Option<Precision<usize>>;
    fn partitions(self: Box<Self>) -> PartitionStream;
}
Expand description

A data source scan produces partitions that can be executed to read data from the source.

Required Methods§

Source

fn dtype(&self) -> &DType

The returned dtype of the scan.

Source

fn partition_count(&self) -> Option<Precision<usize>>

Returns an estimate of the total number of partitions the scan will produce.

Source

fn partitions(self: Box<Self>) -> PartitionStream

Returns a stream of partitions to be processed.

Implementors§