Struct TableScan 

pub struct TableScan {
    pub table_name: String,
    pub source: Arc<dyn DataSource>,
    pub projection: Option<Vec<usize>>,
}

Table scan operator.

Fields

table_name: String

Table name.

source: Arc<dyn DataSource>

Data source.

projection: Option<Vec<usize>>

Projected columns (None means all columns).

Implementations

impl TableScan

pub fn new(table_name: String, source: Arc<dyn DataSource>) -> Self

Create a new table scan.

pub fn with_projection(self, projection: Vec<usize>) -> Self

Set projection.

pub async fn execute(&self) -> Result<Vec<RecordBatch>>

Execute the scan.