Type Alias ArrayRef 

pub type ArrayRef = Arc<dyn Array>;

A reference counted pointer to a dynamic Array trait object.

Aliased Type

pub struct ArrayRef { /* private fields */ }

Trait Implementations

impl ArrayBuiltins for ArrayRef

fn cast(&self, dtype: DType) -> VortexResult<ArrayRef>

Cast to the given data type.

fn get_item(&self, field_name: impl Into<FieldName>) -> VortexResult<ArrayRef>

Get item by field name (for struct types).

fn is_null(&self) -> VortexResult<ArrayRef>

Is null check.

fn mask(&self, mask: &ArrayRef) -> VortexResult<ArrayRef>

Mask the array using the given boolean mask. The resulting array’s validity is the intersection of the original array’s validity and the mask’s validity.

fn not(&self) -> VortexResult<ArrayRef>

Boolean negation.

impl ArrayEq for ArrayRef

fn array_eq(&self, other: &Self, precision: Precision) -> bool

impl ArrayHash for ArrayRef

fn array_hash<H: Hasher>(&self, state: &mut H, precision: Precision)

impl ArrayOptimizer for ArrayRef

fn optimize(&self) -> VortexResult<ArrayRef>

Optimize the root array node only.

fn optimize_recursive(&self) -> VortexResult<ArrayRef>

Optimize the entire array tree recursively.

impl ArrowArrayExecutor for ArrayRef

fn execute_arrow( self, data_type: &DataType, session: &VortexSession, ) -> VortexResult<ArrowArrayRef>

Execute the array to produce an Arrow array.

fn execute_record_batches( self, schema: &Schema, session: &VortexSession, ) -> VortexResult<Vec<RecordBatch>>

Execute the array to produce Arrow RecordBatch’s with the given schema.

fn execute_record_batch( self, schema: &Schema, session: &VortexSession, ) -> VortexResult<RecordBatch>

Execute the array to produce an Arrow RecordBatch with the given schema.

impl From<ArrowArray> for ArrayRef

fn from(value: ArrowArray) -> ArrayRef

Converts to this type from the input type.

impl From<BoolArray> for ArrayRef

fn from(value: BoolArray) -> ArrayRef

Converts to this type from the input type.

impl From<Canonical> for ArrayRef

fn from(value: Canonical) -> Self

Converts to this type from the input type.

impl From<ChunkedArray> for ArrayRef

fn from(value: ChunkedArray) -> ArrayRef

Converts to this type from the input type.

impl From<ConstantArray> for ArrayRef

fn from(value: ConstantArray) -> ArrayRef

Converts to this type from the input type.

impl From<DecimalArray> for ArrayRef

fn from(value: DecimalArray) -> ArrayRef

Converts to this type from the input type.

impl From<DictArray> for ArrayRef

fn from(value: DictArray) -> ArrayRef

Converts to this type from the input type.

impl From<ExtensionArray> for ArrayRef

fn from(value: ExtensionArray) -> ArrayRef

Converts to this type from the input type.

impl From<FilterArray> for ArrayRef

fn from(value: FilterArray) -> ArrayRef

Converts to this type from the input type.

impl From<FixedSizeListArray> for ArrayRef

fn from(value: FixedSizeListArray) -> ArrayRef

Converts to this type from the input type.

impl From<ListArray> for ArrayRef

fn from(value: ListArray) -> ArrayRef

Converts to this type from the input type.

impl From<ListViewArray> for ArrayRef

fn from(value: ListViewArray) -> ArrayRef

Converts to this type from the input type.

impl From<MaskedArray> for ArrayRef

fn from(value: MaskedArray) -> ArrayRef

Converts to this type from the input type.

impl From<NullArray> for ArrayRef

fn from(value: NullArray) -> ArrayRef

Converts to this type from the input type.

impl From<PrimitiveArray> for ArrayRef

fn from(value: PrimitiveArray) -> ArrayRef

Converts to this type from the input type.

impl From<ScalarFnArray> for ArrayRef

fn from(value: ScalarFnArray) -> ArrayRef

Converts to this type from the input type.

impl From<StructArray> for ArrayRef

fn from(value: StructArray) -> ArrayRef

Converts to this type from the input type.

impl From<TemporalArray> for ArrayRef

fn from(value: TemporalArray) -> Self

Converts to this type from the input type.

impl From<VarBinArray> for ArrayRef

fn from(value: VarBinArray) -> ArrayRef

Converts to this type from the input type.

impl From<VarBinViewArray> for ArrayRef

fn from(value: VarBinViewArray) -> ArrayRef

Converts to this type from the input type.

impl FromArrowArray<&BooleanArray> for ArrayRef

fn from_arrow(value: &ArrowBooleanArray, nullable: bool) -> Self

impl FromArrowArray<&FixedSizeListArray> for ArrayRef

fn from_arrow(array: &ArrowFixedSizeListArray, nullable: bool) -> Self

impl<T: ByteArrayType> FromArrowArray<&GenericByteArray<T>> for ArrayRef

where <T as ByteArrayType>::Offset: IntegerPType,

fn from_arrow(value: &GenericByteArray<T>, nullable: bool) -> Self

impl<T: ByteViewType> FromArrowArray<&GenericByteViewArray<T>> for ArrayRef

fn from_arrow(value: &GenericByteViewArray<T>, nullable: bool) -> Self

impl<O: IntegerPType + OffsetSizeTrait> FromArrowArray<&GenericListArray<O>> for ArrayRef

fn from_arrow(value: &GenericListArray<O>, nullable: bool) -> Self

impl<O: OffsetSizeTrait + NativePType> FromArrowArray<&GenericListViewArray<O>> for ArrayRef

fn from_arrow(array: &GenericListViewArray<O>, nullable: bool) -> Self

impl FromArrowArray<&NullArray> for ArrayRef

fn from_arrow(value: &ArrowNullArray, nullable: bool) -> Self

impl FromArrowArray<&PrimitiveArray<Date32Type>> for ArrayRef

fn from_arrow(value: &ArrowPrimitiveArray<Date32Type>, nullable: bool) -> Self

impl FromArrowArray<&PrimitiveArray<Date64Type>> for ArrayRef

fn from_arrow(value: &ArrowPrimitiveArray<Date64Type>, nullable: bool) -> Self

impl FromArrowArray<&PrimitiveArray<Decimal128Type>> for ArrayRef

fn from_arrow( array: &ArrowPrimitiveArray<Decimal128Type>, nullable: bool, ) -> Self

impl FromArrowArray<&PrimitiveArray<Decimal256Type>> for ArrayRef

fn from_arrow( array: &ArrowPrimitiveArray<Decimal256Type>, nullable: bool, ) -> Self

impl FromArrowArray<&PrimitiveArray<Decimal32Type>> for ArrayRef

fn from_arrow( array: &ArrowPrimitiveArray<Decimal32Type>, nullable: bool, ) -> Self

impl FromArrowArray<&PrimitiveArray<Decimal64Type>> for ArrayRef

fn from_arrow( array: &ArrowPrimitiveArray<Decimal64Type>, nullable: bool, ) -> Self

impl FromArrowArray<&PrimitiveArray<Float16Type>> for ArrayRef

fn from_arrow(value: &ArrowPrimitiveArray<Float16Type>, nullable: bool) -> Self

impl FromArrowArray<&PrimitiveArray<Float32Type>> for ArrayRef

fn from_arrow(value: &ArrowPrimitiveArray<Float32Type>, nullable: bool) -> Self

impl FromArrowArray<&PrimitiveArray<Float64Type>> for ArrayRef

fn from_arrow(value: &ArrowPrimitiveArray<Float64Type>, nullable: bool) -> Self

impl FromArrowArray<&PrimitiveArray<Int16Type>> for ArrayRef

fn from_arrow(value: &ArrowPrimitiveArray<Int16Type>, nullable: bool) -> Self

impl FromArrowArray<&PrimitiveArray<Int32Type>> for ArrayRef

fn from_arrow(value: &ArrowPrimitiveArray<Int32Type>, nullable: bool) -> Self

impl FromArrowArray<&PrimitiveArray<Int64Type>> for ArrayRef

fn from_arrow(value: &ArrowPrimitiveArray<Int64Type>, nullable: bool) -> Self

impl FromArrowArray<&PrimitiveArray<Int8Type>> for ArrayRef

fn from_arrow(value: &ArrowPrimitiveArray<Int8Type>, nullable: bool) -> Self

impl FromArrowArray<&PrimitiveArray<Time32MillisecondType>> for ArrayRef

fn from_arrow( value: &ArrowPrimitiveArray<Time32MillisecondType>, nullable: bool, ) -> Self

impl FromArrowArray<&PrimitiveArray<Time32SecondType>> for ArrayRef

fn from_arrow( value: &ArrowPrimitiveArray<Time32SecondType>, nullable: bool, ) -> Self

impl FromArrowArray<&PrimitiveArray<Time64MicrosecondType>> for ArrayRef

fn from_arrow( value: &ArrowPrimitiveArray<Time64MicrosecondType>, nullable: bool, ) -> Self

impl FromArrowArray<&PrimitiveArray<Time64NanosecondType>> for ArrayRef

fn from_arrow( value: &ArrowPrimitiveArray<Time64NanosecondType>, nullable: bool, ) -> Self

impl FromArrowArray<&PrimitiveArray<TimestampMicrosecondType>> for ArrayRef

fn from_arrow( value: &ArrowPrimitiveArray<TimestampMicrosecondType>, nullable: bool, ) -> Self

impl FromArrowArray<&PrimitiveArray<TimestampMillisecondType>> for ArrayRef

fn from_arrow( value: &ArrowPrimitiveArray<TimestampMillisecondType>, nullable: bool, ) -> Self

impl FromArrowArray<&PrimitiveArray<TimestampNanosecondType>> for ArrayRef

fn from_arrow( value: &ArrowPrimitiveArray<TimestampNanosecondType>, nullable: bool, ) -> Self

impl FromArrowArray<&PrimitiveArray<TimestampSecondType>> for ArrayRef

fn from_arrow( value: &ArrowPrimitiveArray<TimestampSecondType>, nullable: bool, ) -> Self

impl FromArrowArray<&PrimitiveArray<UInt16Type>> for ArrayRef

fn from_arrow(value: &ArrowPrimitiveArray<UInt16Type>, nullable: bool) -> Self

impl FromArrowArray<&PrimitiveArray<UInt32Type>> for ArrayRef

fn from_arrow(value: &ArrowPrimitiveArray<UInt32Type>, nullable: bool) -> Self

impl FromArrowArray<&PrimitiveArray<UInt64Type>> for ArrayRef

fn from_arrow(value: &ArrowPrimitiveArray<UInt64Type>, nullable: bool) -> Self

impl FromArrowArray<&PrimitiveArray<UInt8Type>> for ArrayRef

fn from_arrow(value: &ArrowPrimitiveArray<UInt8Type>, nullable: bool) -> Self

impl FromArrowArray<&RecordBatch> for ArrayRef

fn from_arrow(array: &RecordBatch, nullable: bool) -> Self

impl FromArrowArray<&StructArray> for ArrayRef

fn from_arrow(value: &ArrowStructArray, nullable: bool) -> Self

impl FromArrowArray<&dyn Array> for ArrayRef

fn from_arrow(array: &dyn ArrowArray, nullable: bool) -> Self

impl FromArrowArray<RecordBatch> for ArrayRef

fn from_arrow(array: RecordBatch, nullable: bool) -> Self

impl IntoArray for ArrayRef

fn into_array(self) -> ArrayRef

impl IntoArrowArray for ArrayRef

fn into_arrow_preferred(self) -> VortexResult<ArrowArrayRef>

Convert this crate::ArrayRef into an Arrow crate::ArrayRef by using the array’s preferred Arrow DataType.

fn into_arrow(self, data_type: &DataType) -> VortexResult<ArrowArrayRef>

impl MaskExecutor for ArrayRef

fn execute_mask(&self, session: &VortexSession) -> VortexResult<Mask>

Execute the array to produce a mask.

impl ReduceNode for ArrayRef

fn as_any(&self) -> &dyn Any

Downcast to Any.

fn node_dtype(&self) -> VortexResult<DType>

Return the data type of this node.

fn scalar_fn(&self) -> Option<&ScalarFn>

Return this node’s scalar function if it is indeed a scalar fn.

fn child(&self, idx: usize) -> ReduceNodeRef

Descend to the child of this handle.

fn child_count(&self) -> usize

Returns the number of children of this node.

fn children(&self) -> Vec<ReduceNodeRef>

Returns the children of this node.

impl VectorExecutor for ArrayRef

fn execute(&self, ctx: &mut ExecutionCtx) -> VortexResult<Vector>

Recursively execute the array.

fn execute_datum(&self, session: &VortexSession) -> VortexResult<Datum>

Execute the array and return the resulting datum.

fn execute_vector(&self, session: &VortexSession) -> VortexResult<Vector>

Execute the array and return the resulting vector.