Struct Shared 

pub struct Shared;

Implementations

impl Shared

pub fn new(source: ArrayRef) -> SharedArray

Creates a new SharedArray wrapping source.

Trait Implementations

impl Clone for Shared

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Shared

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

Formats the value using the given formatter.

impl OperationsVTable<Shared> for Shared

type ProbeState = SharedProbeState

Encoding-specific state retained by repeated scalar access.

fn probe_scalar( state: &mut ProbeState<'_, Shared>, index: usize, ctx: &mut ExecutionCtx, ) -> VortexResult<Scalar>

Read the scalar at index of the array in state, including its nullness.

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

Fetch the scalar at the given index.

impl VTable for Shared

type TypedArrayData = SharedData

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

type OperationsVTable = Shared

Scalar and element-wise operation hooks for this encoding.

type ValidityVTable = Shared

Validity hook for nullable instances of this encoding.

fn id(&self) -> ArrayId

Returns the ID of the array.

fn validate( &self, _data: &SharedData, 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 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<Shared> for Shared

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

Returns the Validity of the array.