Struct StaticTablesConfigurator 

pub struct StaticTablesConfigurator { /* private fields */ }

A SessionConfigurator that auto-discovers JSON and CSV files under an object store URL and registers each as a queryable DataFusion table.

Table names are derived from the filename stem (e.g., event_schemas.json → event_schemas).

Example

use anyhow::Result;
use datafusion::execution::context::SessionContext;
use micromegas_analytics::lakehouse::static_tables_configurator::StaticTablesConfigurator;
use micromegas_analytics::lakehouse::session_configurator::SessionConfigurator;

#[tokio::main]
async fn main() -> Result<()> {
    let ctx = SessionContext::new();
    let configurator = StaticTablesConfigurator::new(&ctx, "file:///data/tables/").await?;
    // Later, configure a session:
    configurator.configure(&ctx).await?;
    Ok(())
}

Implementations

impl StaticTablesConfigurator

pub async fn from_env( env_var: &str, runtime: Arc<RuntimeEnv>, ) -> Result<Arc<dyn SessionConfigurator>, Error>

Load static tables from the URL in the given environment variable.

Returns NoOpSessionConfigurator when the variable is unset. Errors if the variable is set but loading fails (preserves fail-fast behavior).

pub async fn new( ctx: &SessionContext, url: &str, ) -> Result<StaticTablesConfigurator, Error>

Discovers JSON and CSV files under the given URL and creates table providers for each.

Files with .json extensions are loaded as JSON tables. Files with .csv extensions are loaded as CSV tables. Other extensions are skipped with a warning.

Errors loading individual files are logged but do not prevent other files from loading.

Trait Implementations

impl Debug for StaticTablesConfigurator

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

Formats the value using the given formatter.

impl SessionConfigurator for StaticTablesConfigurator

fn configure<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 SessionContext, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, StaticTablesConfigurator: 'async_trait,

Configure the given SessionContext (e.g., register custom tables)