Struct ElastiCubeBuilder 

pub struct ElastiCubeBuilder { /* private fields */ }

Builder for constructing an ElastiCube

Provides a fluent API for defining dimensions, measures, hierarchies, and loading data from various sources.

Implementations

impl ElastiCubeBuilder

pub fn new(name: impl Into<String>) -> Self

Create a new builder

pub fn add_dimension( self, name: impl Into<String>, data_type: DataType, ) -> Result<Self>

Add a dimension

pub fn add_measure( self, name: impl Into<String>, data_type: DataType, agg_func: AggFunc, ) -> Result<Self>

Add a measure

pub fn add_hierarchy( self, name: impl Into<String>, levels: Vec<String>, ) -> Result<Self>

Add a hierarchy

pub fn add_calculated_measure( self, name: impl Into<String>, expression: impl Into<String>, data_type: DataType, agg_func: AggFunc, ) -> Result<Self>

Add a calculated measure (derived from an expression)

Arguments

• name - Name for the calculated measure
• expression - SQL expression (e.g., “revenue - cost”)
• data_type - Expected result data type
• agg_func - Default aggregation function

Example

let cube = ElastiCubeBuilder::new("sales")
    .add_measure("revenue", DataType::Float64, AggFunc::Sum)?
    .add_measure("cost", DataType::Float64, AggFunc::Sum)?
    .add_calculated_measure(
        "profit",
        "revenue - cost",
        DataType::Float64,
        AggFunc::Sum
    )?
    .build()?;

pub fn add_virtual_dimension( self, name: impl Into<String>, expression: impl Into<String>, data_type: DataType, ) -> Result<Self>

Add a virtual dimension (computed dimension)

Arguments

• name - Name for the virtual dimension
• expression - SQL expression (e.g., “EXTRACT(YEAR FROM date)”)
• data_type - Expected result data type

Example

let cube = ElastiCubeBuilder::new("sales")
    .add_dimension("sale_date", DataType::Date32)?
    .add_virtual_dimension(
        "year",
        "EXTRACT(YEAR FROM sale_date)",
        DataType::Int32
    )?
    .build()?;

pub fn with_description(self, description: impl Into<String>) -> Self

Set the cube description

pub fn load_csv(self, path: impl Into<String>) -> Self

Load data from a CSV file

Arguments

• path - Path to the CSV file

Example

let cube = ElastiCubeBuilder::new("sales")
    .load_csv("data.csv")?
    .build()?;

pub fn load_csv_with(self, source: CsvSource) -> Self

Load data from a CSV file with custom configuration

Arguments

• source - Configured CsvSource

Example

let source = CsvSource::new("data.csv")
    .with_delimiter(b';')
    .with_batch_size(4096);
let cube = ElastiCubeBuilder::new("sales")
    .load_csv_with(source)
    .build()?;

pub fn load_parquet(self, path: impl Into<String>) -> Self

Load data from a Parquet file

Arguments

• path - Path to the Parquet file

pub fn load_parquet_with(self, source: ParquetSource) -> Self

Load data from a Parquet file with custom configuration

pub fn load_json(self, path: impl Into<String>) -> Self

Load data from a JSON file

Arguments

• path - Path to the JSON file

pub fn load_json_with(self, source: JsonSource) -> Self

Load data from a JSON file with custom configuration

pub fn load_record_batches( self, schema: Arc<ArrowSchema>, batches: Vec<RecordBatch>, ) -> Result<Self>

Load data from Arrow RecordBatches

Arguments

• schema - Arrow schema for the batches
• batches - Vector of RecordBatches containing the data

pub fn with_data(self, batches: Vec<RecordBatch>) -> Result<Self>

Load data from RecordBatches (convenience method for testing)

Infers schema from the first batch. All batches must have the same schema.

Arguments

• batches - Vector of RecordBatches containing the data

Example

let batch = RecordBatch::try_new(schema, columns)?;
let cube = ElastiCubeBuilder::new("test")
    .with_data(vec![batch])?
    .build()?;

pub fn build(self) -> Result<ElastiCube>

Build the cube

Loads data from the configured source and creates an ElastiCube. If dimensions and measures were explicitly defined, validates that the data schema matches. Otherwise, infers the schema from the data.

Trait Implementations

impl Debug for ElastiCubeBuilder

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

Formats the value using the given formatter.