Struct TableEntryTableProvider 

pub struct TableEntryTableProvider { /* private fields */ }

Implementations

impl TableEntryTableProvider

pub fn new( client: ConnectionClient, table: impl Into<EntryIdOrName>, runtime: Option<Handle>, ) -> Self

pub fn new_entry_list(client: ConnectionClient, runtime: Option<Handle>) -> Self

pub fn with_analytics(self, origin: Origin) -> Self

Enable per-scan analytics for this provider.

origin identifies the cloud the analytics should be sent to. The caller already holds it (via ConnectionRegistryHandle::client(origin) or similar), so we take it directly to avoid exposing the internal ConnectionAnalytics type.

Without this call no cloud_scan_table span will be emitted.

pub fn with_caller(self, caller: TableQueryCaller) -> Self

Set the caller identity recorded in the analytics span. Has no effect unless Self::with_analytics is also set.

pub fn with_table_kind(self, table_kind: TableKind) -> Self

Set the underlying table kind recorded in the analytics span. Has no effect unless Self::with_analytics is also set.

pub async fn into_provider( self, ) -> Result<Arc<dyn TableProvider>, DataFusionError>

This is a convenience function

Trait Implementations

impl Clone for TableEntryTableProvider

fn clone(&self) -> TableEntryTableProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TableEntryTableProvider

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

Formats the value using the given formatter.