Struct ShreddedSchemaBuilder 

pub struct ShreddedSchemaBuilder {
    root: VariantSchemaNode,
}

Builder for constructing a variant shredding schema.

The builder pattern makes it easy to incrementally define which fields should be shredded and with what types. Fields are nullable by default; pass a (data_type, nullable) pair or a FieldRef to control nullability.

Note: this builder currently only supports struct fields. List support will be added in the future.

Example

use std::sync::Arc;
use arrow::datatypes::{DataType, Field, TimeUnit};
use parquet_variant::{VariantPath, VariantPathElement};
use parquet_variant_compute::ShreddedSchemaBuilder;

// Define the shredding schema using the builder
let shredding_type = ShreddedSchemaBuilder::default()
    // store the "time" field as a separate UTC timestamp
    .with_path("time", (&DataType::Timestamp(TimeUnit::Nanosecond, Some("UTC".into())), true))
    // store hostname as non-nullable Utf8
    .with_path("hostname", (&DataType::Utf8, false))
    // pass a FieldRef directly
    .with_path(
        "metadata.trace_id",
        Arc::new(Field::new("trace_id", DataType::FixedSizeBinary(16), false)),
    )
    // field name with a dot: use VariantPath to avoid splitting
    .with_path(
        VariantPath::from_iter([VariantPathElement::from("metrics.cpu")]),
        &DataType::Float64,
    )
    .build();

// The shredding_type can now be passed to shred_variant:
// let shredded = shred_variant(&input, &shredding_type)?;

Fields

root: VariantSchemaNode

Implementations

impl ShreddedSchemaBuilder

pub fn new() -> ShreddedSchemaBuilder

Create a new empty schema builder.

pub fn with_path<'a, P, F>(self, path: P, field: F) -> ShreddedSchemaBuilder

where P: Into<VariantPath<'a>>, F: IntoShreddingField,

Insert a typed path into the schema using dot notation (or any VariantPath convertible).

The path uses dot notation to specify nested fields. For example, “a.b.c” will create a nested structure.

Arguments

• path - Anything convertible to VariantPath (e.g., a &str)
• field - Anything convertible via IntoShreddingField (e.g. FieldRef, &DataType, or (&DataType, bool) to control nullability)

pub fn build(self) -> DataType

Build the final [DataType].

Trait Implementations

impl Clone for ShreddedSchemaBuilder

fn clone(&self) -> ShreddedSchemaBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ShreddedSchemaBuilder

fn default() -> ShreddedSchemaBuilder

Returns the “default value” for a type.