Struct LiquidCacheClientBuilder 

pub struct LiquidCacheClientBuilder { /* private fields */ }

The builder for LiquidCache client state.

Example

use datafusion::execution::object_store::ObjectStoreUrl;
use datafusion::prelude::SessionConfig;
use liquid_cache_datafusion_client::LiquidCacheClientBuilder;
use std::collections::HashMap;

let mut s3_options = HashMap::new();
s3_options.insert("access_key_id".to_string(), "your-access-key".to_string());
s3_options.insert("secret_access_key".to_string(), "your-secret-key".to_string());
s3_options.insert("region".to_string(), "us-east-1".to_string());

let ctx = LiquidCacheClientBuilder::new("localhost:15214")
    .with_object_store(ObjectStoreUrl::parse("s3://my_bucket").unwrap(), Some(s3_options))
    .build(SessionConfig::from_env().unwrap())
    .unwrap();

ctx.register_parquet("my_table", "s3://my_bucket/my_table.parquet", Default::default())
    .await?;
let df = ctx.sql("SELECT * FROM my_table").await?.show().await?;
println!("{:?}", df);

Implementations

impl LiquidCacheClientBuilder

pub fn new(cache_server: impl AsRef<str>) -> Self

Create a new builder for LiquidCache client state.

pub fn with_object_store( self, url: ObjectStoreUrl, object_store_options: Option<HashMap<String, String>>, ) -> Self

Add an object store to the builder. Checkout https://docs.rs/object_store/latest/object_store/fn.parse_url_opts.html for available options.

pub fn build(self, config: SessionConfig) -> Result<SessionContext>

Build the SessionContext.