Struct LiveTableRegistry 

pub struct LiveTableRegistry { /* private fields */ }

Registry of active live tables and their backing queries.

Internally guarded by an RwLock so concurrent query/contains calls (the common case for REFRESH LIVE TABLE checks and executor query lookups) do not serialise against each other. Writes (register/remove_table) take the write lock. This avoids the Mutex<LiveTableRegistry> contention seen under fan-out of parallel SELECT against live tables in a shared DataFusion SessionContext.

Implementations

impl LiveTableRegistry

pub fn new() -> Self

pub fn try_register( &self, name: impl Into<String>, query: impl Into<String>, ) -> Result<bool, SqlError>

Returns true if the write lock would succeed without blocking. Callers using RwLock semantics may use this to diagnose stalls.

pub fn register( &self, name: impl Into<String>, query: impl Into<String>, ) -> Result<(), SqlError>

pub fn remove_table(&self, name: &str) -> SqlResult<bool>

pub fn contains(&self, name: &str) -> SqlResult<bool>

pub fn query(&self, name: &str) -> SqlResult<Option<String>>

Trait Implementations

impl Debug for LiveTableRegistry

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

Formats the value using the given formatter.

impl Default for LiveTableRegistry

fn default() -> LiveTableRegistry

Returns the “default value” for a type.