Skip to main content

scan_table

Function scan_table 

Source
pub async fn scan_table(
    table: &Table,
    snapshot_id: Option<i64>,
    select_columns: &[String],
) -> Result<Vec<RecordBatch>, ConnectorError>
Expand description

Scans a table and returns all record batches for the current snapshot.

ยงErrors

Returns ConnectorError::ReadError on scan failure.