Struct LiquidCacheTableBuilder

pub struct LiquidCacheTableBuilder { /* private fields */ }

The builder for a LiquidCacheTable.

Example

let mut session_config = SessionConfig::from_env()?;
session_config
    .options_mut()
    .execution
    .parquet
    .pushdown_filters = true;
let ctx = Arc::new(SessionContext::new_with_config(session_config));
let table = LiquidCacheTableBuilder::new(cache_server, table_name, url.as_ref())
    .with_object_store(
        format!("{}://{}", url.scheme(), url.host_str().unwrap_or_default()),
        None,
    )
    .build()
    .await?;
ctx.register_table(table_name, Arc::new(table))?;
ctx.sql(&sql).await?.show().await?;

Implementations

impl LiquidCacheTableBuilder

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

Create a new builder for a LiquidCacheTable.

Arguments

• cache_server - The address of the cache server
• table_name - The name of the table
• table_url - The url of the table

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

Add an object store to the builder.

Arguments

• url - The url of the object store
• object_store_options - The options for the object store

Example

use liquid_cache_client::LiquidCacheTableBuilder;
use std::collections::HashMap;

let mut builder = LiquidCacheTableBuilder::new("localhost:50051", "my_table", "my_table_url");
let object_store_options = HashMap::new();
builder.with_object_store("s3://my_bucket", Some(object_store_options)).build();

pub fn with_cache_mode(self, cache_mode: CacheMode) -> Self

Set the cache mode for the builder.

Arguments

• cache_mode - The cache mode to use

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

Build the LiquidCacheTable. It will communicate with the cache server to get the metadata of the table.

Trait Implementations

impl Clone for LiquidCacheTableBuilder

fn clone(&self) -> LiquidCacheTableBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for LiquidCacheTableBuilder

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

Formats the value using the given formatter.