Struct LiquidCacheLocalBuilder 

pub struct LiquidCacheLocalBuilder { /* private fields */ }

Builder for in-process liquid cache session context

This allows you to use liquid cache within the same process, instead of using the client-server architecture as in the default mode.

Example

use liquid_cache_local::{
    storage::cache_policies::LiquidPolicy,
    LiquidCacheLocalBuilder,
};
use datafusion::prelude::{SessionConfig, SessionContext};
use tempfile::TempDir;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let temp_dir = TempDir::new().unwrap();

    let (ctx, _) = LiquidCacheLocalBuilder::new()
        .with_max_cache_bytes(1024 * 1024 * 1024) // 1GB
        .with_cache_dir(temp_dir.path().to_path_buf())
        .with_cache_policy(Box::new(LiquidPolicy::new()))
        .build(SessionConfig::new())?;

    // Register the test parquet file
    ctx.register_parquet("hits", "../../examples/nano_hits.parquet", Default::default())
        .await?;

    ctx.sql("SELECT COUNT(*) FROM hits").await?.show().await?;
    Ok(())
}

Implementations

impl LiquidCacheLocalBuilder

pub fn new() -> Self

Create a new builder with defaults

pub fn with_batch_size(self, batch_size: usize) -> Self

Set batch size

pub fn with_max_cache_bytes(self, max_cache_bytes: usize) -> Self

Set maximum cache size in bytes

pub fn with_cache_dir(self, cache_dir: PathBuf) -> Self

Set cache directory

pub fn with_squeeze_policy(self, squeeze_policy: Box<dyn SqueezePolicy>) -> Self

Set squeeze policy

pub fn with_cache_policy(self, cache_policy: Box<dyn CachePolicy>) -> Self

Set cache strategy

pub fn with_span(self, span: Span) -> Self

Set fastrace span

pub fn with_io_mode(self, io_mode: IoMode) -> Self

Set IO mode

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

Build a SessionContext with liquid cache configured Returns the SessionContext and the liquid cache reference

Trait Implementations

impl Default for LiquidCacheLocalBuilder

fn default() -> Self

Returns the “default value” for a type.