Struct OpenSearchTableFactory 

pub struct OpenSearchTableFactory { /* private fields */ }

Builds OpenSearchTableProviders over one cluster, deriving each table’s schema from the index _mapping unless one is declared.

Implementations

impl OpenSearchTableFactory

pub fn new(client: OpenSearchClient) -> Self

pub fn client(&self) -> &OpenSearchClient

The client every table built here shares.

pub async fn table_provider( &self, index: impl Into<String>, ) -> Result<Arc<dyn TableProvider>>

A table over index whose schema is derived from its _mapping (schema_from_mapping). Fails if the index does not exist or has no properties.

pub async fn provider( &self, index: impl Into<String>, ) -> Result<OpenSearchTableProvider>

Like table_provider, not type-erased, for the builder methods.

pub fn table_provider_with_schema( &self, index: impl Into<String>, schema: SchemaRef, ) -> Arc<dyn TableProvider>

A table over index with a declared schema (no _mapping round-trip; only the listed columns are read, and a not-yet-created index reads as empty).

pub fn provider_with_schema( &self, index: impl Into<String>, schema: SchemaRef, ) -> OpenSearchTableProvider

The provider (not type-erased), for callers that want the builder methods.

Trait Implementations

impl Clone for OpenSearchTableFactory

fn clone(&self) -> OpenSearchTableFactory

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OpenSearchTableFactory

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

Formats the value using the given formatter.