Struct UnityObjectStoreFactoryBuilder 

pub struct UnityObjectStoreFactoryBuilder { /* private fields */ }

Builder for UnityObjectStoreFactory.

Implementations

impl UnityObjectStoreFactoryBuilder

pub fn new() -> Self

pub fn with_uri(self, uri: impl Into<String>) -> Self

Set the URI of the Unity Catalog API (e.g. https://<workspace>/api/2.1/unity-catalog/).

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

Set the access token used for bearer authentication.

Accepts both String and Option<String> — pass None to clear a previously-set token (e.g. when reusing the builder).

pub fn with_allow_unauthenticated(self, allow_unauthenticated: bool) -> Self

Allow construction without any authentication credentials.

Only intended for local development against an unauthenticated OSS Unity Catalog server — there should not be any unauthenticated UC servers in production deployments.

pub fn with_aws_region(self, aws_region: impl Into<Option<String>>) -> Self

Override the AWS region used for vended AWS credentials.

When unset the factory falls back to (in order):

1. The AWS_REGION environment variable.
2. The object_store default region (us-east-1).

This is a stop-gap until the server reliably returns region info alongside the credential.

pub fn with_io_runtime(self, handle: impl Into<Option<Handle>>) -> Self

Route all HTTP I/O onto a dedicated tokio runtime.

In production DataFusion deployments it is common to segregate network I/O onto a separate runtime so that CPU-bound query work on the main runtime cannot starve object-store requests (and vice versa). When a handle is supplied here:

• every cloud object store (AmazonS3Builder, MicrosoftAzureBuilder, GoogleCloudStorageBuilder) is built with a SpawnedReqwestConnector that spawns its requests on this runtime; and
• the credential-vending [CloudClient] is configured with the same runtime via [CloudClient::with_runtime].

When unset (the default), I/O runs on the ambient runtime — current behaviour, fully backwards compatible.

Pass None to clear a previously set handle (e.g. when reusing the builder).

Not available on wasm32: the browser has a single-threaded executor and no tokio runtime to route I/O onto.

pub async fn build(self) -> Result<UnityObjectStoreFactory>

Trait Implementations

impl Clone for UnityObjectStoreFactoryBuilder

fn clone(&self) -> UnityObjectStoreFactoryBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UnityObjectStoreFactoryBuilder

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

Formats the value using the given formatter.

impl Default for UnityObjectStoreFactoryBuilder

fn default() -> UnityObjectStoreFactoryBuilder

Returns the “default value” for a type.