ExonRuntimeEnvExt

exon

Trait ExonRuntimeEnvExt 

Source 
pub trait ExonRuntimeEnvExt {
    // Required methods
    fn register_s3_object_store<'life0, 'life1, 'async_trait>(
        &'life0 self,
        url: &'life1 Url,
    ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ObjectStore>>, DataFusionError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn exon_register_object_store_url<'life0, 'life1, 'async_trait>(
        &'life0 self,
        url: &'life1 Url,
    ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ObjectStore>>, DataFusionError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn exon_register_object_store_uri<'life0, 'life1, 'async_trait>(
        &'life0 self,
        uri: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ObjectStore>>, DataFusionError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}
Expand description

Extension trait for RuntimeEnv that provides additional methods for Exon use-cases.

For example, you can use this trait to register an S3 object store with the given URL, that’s backed by the default AWS credential chain.

Required Methods§

Source

fn register_s3_object_store<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 Url, ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ObjectStore>>, DataFusionError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Register an S3 object store with the given URL, that’s backed by the default AWS credential chain.

Returns the previous object store registered for this URL, if any.

Source

fn exon_register_object_store_url<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 Url, ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ObjectStore>>, DataFusionError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Register an object store “intelligently” given the URL.

Source

fn exon_register_object_store_uri<'life0, 'life1, 'async_trait>( &'life0 self, uri: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ObjectStore>>, DataFusionError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Register an object store with the given URI.

Implementations on Foreign Types§

Source§

impl ExonRuntimeEnvExt for Arc<RuntimeEnv>

Source§

fn exon_register_object_store_url<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 Url, ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ObjectStore>>, DataFusionError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Register an object store “intelligently” given the URL.

Source§

fn exon_register_object_store_uri<'life0, 'life1, 'async_trait>( &'life0 self, uri: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ObjectStore>>, DataFusionError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Register an object store with the given URI.

Source§

fn register_s3_object_store<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 Url, ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ObjectStore>>, DataFusionError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Implementors§