Struct TableStore 

pub struct TableStore { /* private fields */ }

Opaque handle to the shared table storage.

External crates receive this capability via DatabaseScanner::table_store(). The raw storage map is not part of the public API.

Table-store invariants (TS-*)

• TS-1 (opaque capability): External crates do not receive the raw Arc<StdMutex<HashMap<...>>>.
• TS-2 (behavior parity): TableStore::ingest_batch preserves existing ingestion semantics (ID-1 through ID-6).
• TS-3 (read capability minimality): table_names and table_provider expose only what downstream query setup needs. Callers receive Arc<dyn TableProvider>, not the backing MemTable.
• TS-4 (ownership preserved): Storage ownership remains in monarch_distributed_telemetry. TableStore is a handle, not an independent store.

Implementations

impl TableStore

pub fn new_empty() -> Self

Create an empty standalone table store.

Useful for testing or standalone ingestion scenarios where the full DatabaseScanner lifecycle is not needed.

pub async fn ingest_batch( &self, table_name: &str, batch: RecordBatch, ) -> Result<()>

Ingest a RecordBatch into a named table (TS-2).

Async so callers in async contexts can await directly without hitting the block_in_place bridge in push_batch_to_tables.

See the ID-* invariants on DatabaseScanner::push_batch_to_tables for behavioral guarantees (this method preserves the same semantics).

pub fn table_names(&self) -> Result<Vec<String>>

Return sorted table names currently in storage (TS-3).

pub fn table_provider( &self, table_name: &str, ) -> Result<Option<Arc<dyn TableProvider>>>

Return a [TableProvider] for a named table, or None if the table does not exist (TS-3).

The returned provider can be registered directly with a DataFusion SessionContext. Callers do not see the backing storage type.

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.