Struct TableStore 

pub struct TableStore { /* private fields */ }

Implementations

impl TableStore

pub fn new(root_uri: &str) -> Self

pub fn root_uri(&self) -> &str

pub fn dataset_uri(&self, table_path: &str) -> String

pub async fn open_snapshot_table( &self, snapshot: &Snapshot, table_key: &str, ) -> Result<Dataset>

pub async fn open_at_entry(&self, entry: &SubTableEntry) -> Result<Dataset>

pub async fn open_dataset_head( &self, dataset_uri: &str, branch: Option<&str>, ) -> Result<Dataset>

pub async fn open_dataset_head_for_write( &self, table_key: &str, dataset_uri: &str, branch: Option<&str>, ) -> Result<Dataset>

pub async fn delete_branch(&self, dataset_uri: &str, branch: &str) -> Result<()>

pub async fn open_dataset_at_state( &self, table_path: &str, branch: Option<&str>, version: u64, ) -> Result<Dataset>

pub fn ensure_expected_version( &self, ds: &Dataset, table_key: &str, expected_version: u64, ) -> Result<()>

pub async fn reopen_for_mutation( &self, dataset_uri: &str, branch: Option<&str>, table_key: &str, expected_version: u64, ) -> Result<Dataset>

pub async fn fork_branch_from_state( &self, dataset_uri: &str, source_branch: Option<&str>, table_key: &str, source_version: u64, target_branch: &str, ) -> Result<Dataset>

pub async fn scan_batches(&self, ds: &Dataset) -> Result<Vec<RecordBatch>>

pub async fn scan_batches_for_rewrite( &self, ds: &Dataset, ) -> Result<Vec<RecordBatch>>

pub async fn scan_stream( ds: &Dataset, projection: Option<&[&str]>, filter: Option<&str>, order_by: Option<Vec<ColumnOrdering>>, with_row_id: bool, ) -> Result<DatasetRecordBatchStream>

pub async fn scan_stream_with<F>( ds: &Dataset, projection: Option<&[&str]>, filter: Option<&str>, order_by: Option<Vec<ColumnOrdering>>, with_row_id: bool, configure: F, ) -> Result<DatasetRecordBatchStream>

where F: FnOnce(&mut Scanner) -> Result<()>,

pub async fn scan( &self, ds: &Dataset, projection: Option<&[&str]>, filter: Option<&str>, order_by: Option<Vec<ColumnOrdering>>, ) -> Result<Vec<RecordBatch>>

pub async fn scan_with<F>( &self, ds: &Dataset, projection: Option<&[&str]>, filter: Option<&str>, order_by: Option<Vec<ColumnOrdering>>, with_row_id: bool, configure: F, ) -> Result<Vec<RecordBatch>>

where F: FnOnce(&mut Scanner) -> Result<()>,

pub async fn count_rows( &self, ds: &Dataset, filter: Option<String>, ) -> Result<usize>

pub fn dataset_version(&self, ds: &Dataset) -> u64

pub async fn table_state( &self, dataset_uri: &str, ds: &Dataset, ) -> Result<TableState>

pub async fn append_batch( &self, dataset_uri: &str, ds: &mut Dataset, batch: RecordBatch, ) -> Result<TableState>

pub async fn append_or_create_batch( dataset_uri: &str, dataset: Option<Dataset>, batch: RecordBatch, ) -> Result<Dataset>

pub async fn overwrite_batch( &self, dataset_uri: &str, ds: &mut Dataset, batch: RecordBatch, ) -> Result<TableState>

pub async fn overwrite_dataset( dataset_uri: &str, batch: RecordBatch, ) -> Result<Dataset>

pub async fn merge_insert_batch( &self, dataset_uri: &str, ds: Dataset, batch: RecordBatch, key_columns: Vec<String>, when_matched: WhenMatched, when_not_matched: WhenNotMatched, ) -> Result<TableState>

pub async fn merge_insert_batches( &self, dataset_uri: &str, ds: Dataset, batches: Vec<RecordBatch>, key_columns: Vec<String>, when_matched: WhenMatched, when_not_matched: WhenNotMatched, ) -> Result<TableState>

pub async fn delete_where( &self, dataset_uri: &str, ds: &mut Dataset, filter: &str, ) -> Result<DeleteState>

pub async fn has_btree_index(&self, ds: &Dataset, column: &str) -> Result<bool>

pub async fn has_fts_index(&self, ds: &Dataset, column: &str) -> Result<bool>

pub async fn has_vector_index(&self, ds: &Dataset, column: &str) -> Result<bool>

pub async fn create_btree_index( &self, ds: &mut Dataset, columns: &[&str], ) -> Result<()>

pub async fn create_inverted_index( &self, ds: &mut Dataset, column: &str, ) -> Result<()>

pub async fn create_vector_index( &self, ds: &mut Dataset, column: &str, ) -> Result<()>

pub async fn create_empty_dataset( dataset_uri: &str, schema: &SchemaRef, ) -> Result<Dataset>

pub async fn first_row_id_for_filter( &self, ds: &Dataset, filter: &str, ) -> Result<Option<u64>>

pub async fn write_dataset( dataset_uri: &str, batch: RecordBatch, ) -> Result<Dataset>

Trait Implementations

impl Clone for TableStore

fn clone(&self) -> TableStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TableStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.