Struct LiquidCacheBuilder

pub struct LiquidCacheBuilder { /* private fields */ }

The builder for LiquidCache client state.

Example

use liquid_cache_client::LiquidCacheBuilder;
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 = LiquidCacheBuilder::new("localhost:15214")
    .with_object_store("s3://my_bucket", Some(s3_options))
    .with_cache_mode(CacheMode::Liquid)
    .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 LiquidCacheBuilder

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 with_cache_mode(self, cache_mode: CacheMode) -> Self

Set the cache mode for the builder.

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

Build the SessionContext.