Struct LiquidFixedLenByteArray 

pub struct LiquidFixedLenByteArray { /* private fields */ }

A fixed length byte array.

Implementations

impl LiquidFixedLenByteArray

pub fn from_bytes(bytes: Bytes, compressor: Arc<Compressor>) -> Self

Deserialize a LiquidFixedLenByteArray from bytes, using zero-copy where possible.

impl LiquidFixedLenByteArray

pub fn from_decimal_array<T: DecimalType>( array: &PrimitiveArray<T>, compressor: Arc<Compressor>, ) -> Self

Create a new fixed length byte array from a decimal array.

pub fn train_from_decimal_array<T: DecimalType>( array: &PrimitiveArray<T>, ) -> (Arc<Compressor>, Self)

Train a new fixed length byte array from a decimal array.

Trait Implementations

impl Debug for LiquidFixedLenByteArray

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

Formats the value using the given formatter.

impl LiquidArray for LiquidFixedLenByteArray

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(&self) -> ArrayRef

Convert the Liquid array to an Arrow array.

fn to_best_arrow_array(&self) -> ArrayRef

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 original_arrow_data_type(&self) -> DataType

Get the original arrow data type of the Liquid array.

fn to_bytes(&self) -> Vec<u8>

Serialize the Liquid array to a byte array.

fn data_type(&self) -> LiquidDataType

Get the logical data type of the Liquid array.

fn is_empty(&self) -> bool

Check if the Liquid array is empty.

fn filter(&self, selection: &BooleanBuffer) -> ArrayRef

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

fn try_eval_predicate( &self, _predicate: &Arc<dyn PhysicalExpr>, _filter: &BooleanBuffer, ) -> Option<BooleanArray>

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

fn squeeze( &self, _io: Arc<dyn SqueezeIoHandler>, _expression_hint: Option<&CacheExpression>, ) -> Option<(LiquidSqueezedArrayRef, Bytes)>

Squeeze the Liquid array to a LiquidHybridArrayRef and a bytes::Bytes. Return None if the Liquid array cannot be squeezed.