Struct RunEnd 

pub struct RunEnd;

Implementations

impl RunEnd

pub unsafe fn new_unchecked( ends: ArrayRef, values: ArrayRef, offset: usize, length: usize, ) -> RunEndArray

Build a new RunEndArray without validation.

Safety

See RunEndData::new_unchecked for preconditions.

pub fn try_new( ends: ArrayRef, values: ArrayRef, ctx: &mut ExecutionCtx, ) -> VortexResult<RunEndArray>

Build a new RunEndArray from ends and values.

pub fn try_new_offset_length( ends: ArrayRef, values: ArrayRef, offset: usize, length: usize, ctx: &mut ExecutionCtx, ) -> VortexResult<RunEndArray>

Build a new RunEndArray from ends, values, offset, and length.

pub fn new( ends: ArrayRef, values: ArrayRef, ctx: &mut ExecutionCtx, ) -> RunEndArray

Build a new RunEndArray from ends and values (panics on invalid input).

pub fn encode( array: ArrayRef, ctx: &mut ExecutionCtx, ) -> VortexResult<RunEndArray>

Run the array through run-end encoding.

Trait Implementations

impl CastReduce for RunEnd

fn cast( array: ArrayView<'_, Self>, dtype: &DType, ) -> VortexResult<Option<ArrayRef>>

impl Clone for RunEnd

fn clone(&self) -> RunEnd

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CompareKernel for RunEnd

fn compare( lhs: ArrayView<'_, Self>, rhs: &ArrayRef, operator: CompareOperator, ctx: &mut ExecutionCtx, ) -> VortexResult<Option<ArrayRef>>

impl Debug for RunEnd

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

Formats the value using the given formatter.

impl FillNullReduce for RunEnd

fn fill_null( array: ArrayView<'_, Self>, fill_value: &Scalar, ) -> VortexResult<Option<ArrayRef>>

impl FilterKernel for RunEnd

fn filter( array: ArrayView<'_, Self>, mask: &Mask, ctx: &mut ExecutionCtx, ) -> VortexResult<Option<ArrayRef>>

Filter an array with the provided mask, potentially reading buffers.

impl OperationsVTable<RunEnd> for RunEnd

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

Fetch the scalar at the given index.

impl TakeExecute for RunEnd

fn take( array: ArrayView<'_, Self>, indices: &ArrayRef, ctx: &mut ExecutionCtx, ) -> VortexResult<Option<ArrayRef>>

Take elements from an array at the given indices, potentially reading buffers.

impl VTable for RunEnd

type TypedArrayData = RunEndData

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

type OperationsVTable = RunEnd

Scalar and element-wise operation hooks for this encoding.

type ValidityVTable = RunEnd

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 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 slot_name(_array: ArrayView<'_, Self>, idx: usize) -> String

Returns the name of the slot at the given index.

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

Attempt to reduce parent after this array appears as one of its 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.

impl ValidityVTable<RunEnd> for RunEnd

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

Returns the Validity of the array.