Struct OpenSearchTableProviderFactory 

pub struct OpenSearchTableProviderFactory { /* private fields */ }

The TableProviderFactory that makes OpenSearch indices reachable from SQL alone:

CREATE EXTERNAL TABLE docs STORED AS OPENSEARCH LOCATION 'http://localhost:9200/my-index';

LOCATION is <base url>/<index>. Without a column list the schema is derived from the index _mapping; with one, only those columns are read. Recognised OPTIONS: page_size, max_rows, partitions, sort ("field:asc,other:desc"), base_filter (a JSON array of query-DSL clauses). Credentials and the HTTP client set on the factory apply to every table it creates.

Implementations

impl OpenSearchTableProviderFactory

pub fn new() -> Self

pub fn with_client(self, http: Client) -> Self

Use this reqwest::Client for every table (timeouts, TLS roots, headers).

pub fn with_basic_auth( self, user: impl Into<String>, password: impl Into<String>, ) -> Self

Send HTTP basic credentials with every request.

pub fn with_bearer_token(self, token: impl Into<String>) -> Self

Send a bearer token with every request.

pub fn register(self, ctx: &SessionContext)

Register this factory on a SessionContext as STORED AS OPENSEARCH.

Trait Implementations

impl Clone for OpenSearchTableProviderFactory

fn clone(&self) -> OpenSearchTableProviderFactory

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OpenSearchTableProviderFactory

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

Formats the value using the given formatter.

impl Default for OpenSearchTableProviderFactory

fn default() -> OpenSearchTableProviderFactory

Returns the “default value” for a type.

impl TableProviderFactory for OpenSearchTableProviderFactory

fn create<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _state: &'life1 dyn Session, cmd: &'life2 CreateExternalTable, ) -> Pin<Box<dyn Future<Output = DataFusionResult<Arc<dyn TableProvider>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Create a TableProvider with the given url