Struct VariantStructSqueezedArray 

pub struct VariantStructSqueezedArray { /* private fields */ }

Squeezed representation for variant arrays that contain multiple typed fields.

Implementations

impl VariantStructSqueezedArray

pub fn new( values: Vec<(Arc<str>, LiquidArrayRef)>, nulls: Option<NullBuffer>, original_arrow_type: DataType, ) -> Self

Create a squeezed representation that keeps only the typed variant columns resident.

pub fn contains_path(&self, path: &str) -> bool

Returns true if the squeezed contains the provided variant path.

pub fn to_arrow_array_with_paths<'a>( &self, paths: impl IntoIterator<Item = &'a str>, ) -> Result<ArrayRef, NeedsBacking>

Build an Arrow array that includes only the provided variant paths. If paths is empty or none match, it falls back to the full array.

pub fn typed_values(&self) -> Vec<(Arc<str>, LiquidArrayRef)>

Clone the stored typed values keyed by variant path.

pub fn nulls(&self) -> Option<NullBuffer>

Null buffer shared by all stored paths, if present.

Trait Implementations

impl Debug for VariantStructSqueezedArray

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

Formats the value using the given formatter.

impl LiquidSqueezedArray for VariantStructSqueezedArray

fn as_any(&self) -> &dyn Any

Get the underlying any type.

fn get_array_memory_size(&self) -> usize

Get the memory size of the Liquid array.

fn len(&self) -> usize

Get the length of the Liquid array.

fn to_arrow_array<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ArrayRef> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Convert the Liquid array to an Arrow array.

fn data_type(&self) -> LiquidDataType

Get the logical data type of the Liquid array.

fn original_arrow_data_type(&self) -> DataType

Get the original arrow data type of the Liquid squeezed array.

fn disk_backing(&self) -> SqueezedBacking

Describe how the squeezed array persists its backing bytes on disk.

fn is_empty(&self) -> bool

Check if the Liquid array is empty.

fn to_best_arrow_array<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ArrayRef> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Convert the Liquid array to an Arrow array. Except that it will pick the best encoding for the arrow array. Meaning that it may not obey the data type of the original arrow array.

fn filter<'life0, 'life1, 'async_trait>( &'life0 self, selection: &'life1 BooleanBuffer, ) -> Pin<Box<dyn Future<Output = ArrayRef> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Filter the Liquid array with a boolean array and return an arrow array.

fn try_eval_predicate<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _predicate: &'life1 Arc<dyn PhysicalExpr>, _filter: &'life2 BooleanBuffer, ) -> Pin<Box<dyn Future<Output = Option<BooleanArray>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Try to evaluate a predicate on the Liquid array with a filter. Returns Ok(None) if the predicate is not supported.