Struct ZstdBuffers 

pub struct ZstdBuffers;

Encoding marker for buffer-level zstd compression.

Implementations

impl ZstdBuffers

pub fn try_new( dtype: DType, len: usize, data: ZstdBuffersData, ) -> VortexResult<ZstdBuffersArray>

Construct a ZstdBuffersArray from compressed buffer data.

pub fn compress( array: &ArrayRef, level: i32, session: &VortexSession, ) -> VortexResult<ZstdBuffersArray>

Compress every top-level buffer of array independently with zstd.

Children are preserved as slots and the wrapped array’s serialized metadata is stored so the original array can be rebuilt after decompression.

pub fn build_inner( array: &ZstdBuffersArray, buffer_handles: &[BufferHandle], session: &VortexSession, ) -> VortexResult<ArrayRef>

Rebuild the wrapped array from decompressed buffer handles.

Trait Implementations

impl Clone for ZstdBuffers

fn clone(&self) -> ZstdBuffers

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ZstdBuffers

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

Formats the value using the given formatter.

impl OperationsVTable<ZstdBuffers> for ZstdBuffers

fn scalar_at( array: ArrayView<'_, ZstdBuffers>, index: usize, ctx: &mut ExecutionCtx, ) -> VortexResult<Scalar>

Fetch the scalar at the given index.

impl VTable for ZstdBuffers

type TypedArrayData = ZstdBuffersData

Per-array data owned by this encoding, excluding child arrays.

type OperationsVTable = ZstdBuffers

Scalar and element-wise operation hooks for this encoding.

type ValidityVTable = ZstdBuffers

Validity hook for nullable instances of this encoding.

fn id(&self) -> ArrayId

Returns the ID of the array.

fn validate( &self, data: &Self::TypedArrayData, _dtype: &DType, _len: usize, _slots: &[Option<ArrayRef>], ) -> VortexResult<()>

Validates that externally supplied logical metadata matches the array data.

fn nbuffers(array: ArrayView<'_, Self>) -> usize

Returns the number of top-level buffers in the array.

fn buffer(array: ArrayView<'_, Self>, idx: usize) -> BufferHandle

Returns the buffer at the given index.

fn buffer_name(_array: ArrayView<'_, Self>, idx: usize) -> Option<String>

Returns the name of the buffer at the given index, or None if unnamed.

fn with_buffers( &self, array: ArrayView<'_, Self>, buffers: &[BufferHandle], ) -> VortexResult<ArrayParts<Self>>

Rebuild this array with replacement top-level buffers.

fn slot_name(_array: ArrayView<'_, Self>, idx: usize) -> String

Returns the name of the slot at the given index.

fn serialize( array: ArrayView<'_, Self>, _session: &VortexSession, ) -> VortexResult<Option<Vec<u8>>>

Serialize encoding metadata into a byte buffer for IPC or file storage.

fn deserialize( &self, dtype: &DType, len: usize, metadata: &[u8], buffers: &[BufferHandle], children: &dyn ArrayChildren, session: &VortexSession, ) -> VortexResult<ArrayParts<Self>>

Deserialize an array from serialized metadata, buffers, and children.

fn execute( array: Array<Self>, ctx: &mut ExecutionCtx, ) -> VortexResult<ExecutionResult>

Execute this array by returning an ExecutionResult.

fn nchildren(array: ArrayView<'_, Self>) -> usize

Returns the number of children in the array.

fn child(array: ArrayView<'_, Self>, idx: usize) -> ArrayRef

Returns the child at the given index.

fn child_name(array: ArrayView<'_, Self>, idx: usize) -> String

Returns the name of the child at the given index.

fn append_to_builder( array: ArrayView<'_, Self>, builder: &mut dyn ArrayBuilder, ctx: &mut ExecutionCtx, ) -> Result<(), VortexError>

Writes the array’s logical values into a canonical builder.

fn reduce(array: ArrayView<'_, Self>) -> Result<Option<ArrayRef>, VortexError>

Attempt to reduce the array to a simpler representation without changing logical values.

fn reduce_parent( array: ArrayView<'_, Self>, parent: &ArrayRef, child_idx: usize, ) -> Result<Option<ArrayRef>, VortexError>

Attempt to reduce parent after this array appears as one of its children.

impl ValidityVTable<ZstdBuffers> for ZstdBuffers

fn validity(array: ArrayView<'_, ZstdBuffers>) -> VortexResult<Validity>

Returns the Validity of the array.