FoRVTable

Struct FoRVTable 

Source
pub struct FoRVTable;

Trait Implementations§

Source§

impl BaseArrayVTable<FoRVTable> for FoRVTable

Source§

fn len(array: &FoRArray) -> usize

Source§

fn dtype(array: &FoRArray) -> &DType

Source§

fn stats(array: &FoRArray) -> StatsSetRef<'_>

Source§

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

Source§

fn array_eq(array: &FoRArray, other: &FoRArray, precision: Precision) -> bool

Source§

impl CanonicalVTable<FoRVTable> for FoRVTable

Source§

fn canonicalize(array: &FoRArray) -> Canonical

Returns the canonical representation of the array. Read more
Source§

fn append_to_builder( array: &<V as VTable>::Array, builder: &mut dyn ArrayBuilder, )

Writes the array into a canonical builder. Read more
Source§

impl CastKernel for FoRVTable

Source§

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

Source§

impl CompareKernel for FoRVTable

Source§

fn compare( &self, lhs: &FoRArray, rhs: &dyn Array, operator: Operator, ) -> VortexResult<Option<ArrayRef>>

Source§

impl Debug for FoRVTable

Source§

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

Formats the value using the given formatter. Read more
Source§

impl EncodeVTable<FoRVTable> for FoRVTable

Source§

fn encode( _vtable: &FoRVTable, canonical: &Canonical, _like: Option<&FoRArray>, ) -> VortexResult<Option<FoRArray>>

Try to encode a canonical array into this encoding. Read more
Source§

impl FilterKernel for FoRVTable

Source§

fn filter(&self, array: &FoRArray, mask: &Mask) -> VortexResult<ArrayRef>

Filter an array by the provided predicate. Read more
Source§

impl IsConstantKernel for FoRVTable

Source§

fn is_constant( &self, array: &FoRArray, opts: &IsConstantOpts, ) -> VortexResult<Option<bool>>

Preconditions Read more
Source§

impl IsSortedKernel for FoRVTable

FoR can express sortedness directly on its encoded form.

If the minimum is greater than or equal to zero, subtracting it from the other values does not wrap (the value always decreases and the smallest value is zero because min - min = 0).

Subtraction without wrapping is order-preserving, so we only need to consider what happens to wrapped numbers.

Non-negative minimum values can’t wrap. For a negative minimum value, wrapping means that

a + abs(min) > 127

There’s some residue r,

r < 128

such that

a + abs(min) mod 128 = r

For example,

min = -128
a = 1

1 - -128 = 129

And 129’s residue is 1. 129 is represented as

-128 + 1 = -127

The unsigned representation is

2^8 - 127

More directly, for some residue r:

2^8 + (-128 + r)
  = 2^8 - 128 + r
  = 128 + r

Addition is order-preserving, so all the wrapped values preserve their order and they’re all represented as unsigned values larger than 127 so they also preserve their order with the unwrapped values.

Source§

impl OperationsVTable<FoRVTable> for FoRVTable

Source§

fn slice(array: &FoRArray, range: Range<usize>) -> ArrayRef

Perform a constant-time slice of the array. Read more
Source§

fn scalar_at(array: &FoRArray, index: usize) -> Scalar

Fetch the scalar at the given index. Read more
Source§

impl TakeKernel for FoRVTable

Source§

fn take(&self, array: &FoRArray, indices: &dyn Array) -> VortexResult<ArrayRef>

Create a new array by taking the values from the array at the given indices. Read more
Source§

impl VTable for FoRVTable

Source§

type Array = FoRArray

Source§

type Metadata = ScalarValueMetadata

Source§

type ArrayVTable = FoRVTable

Source§

type CanonicalVTable = FoRVTable

Source§

type OperationsVTable = FoRVTable

Source§

type ValidityVTable = ValidityVTableFromChild

Source§

type VisitorVTable = FoRVTable

Source§

type ComputeVTable = NotSupported

Optionally enable implementing dynamic compute dispatch for this encoding. Can be disabled by assigning to the NotSupported type.
Source§

type EncodeVTable = FoRVTable

Optionally enable the EncodeVTable for this encoding. This allows it to partake in compression. Can be disabled by assigning to the NotSupported type.
Source§

fn id(&self) -> ArrayId

Returns the ID of the encoding.
Source§

fn encoding(_array: &Self::Array) -> ArrayVTable

Returns the encoding for the array.
Source§

fn with_children( array: &mut Self::Array, children: Vec<ArrayRef>, ) -> VortexResult<()>

Replaces the children in array with children. The count must be the same and types of children must be expected.
Source§

fn metadata(array: &FoRArray) -> VortexResult<Self::Metadata>

Exports metadata for an array. Read more
Source§

fn serialize(metadata: Self::Metadata) -> VortexResult<Option<Vec<u8>>>

Serialize metadata into a byte buffer for IPC or file storage. Return None if the array cannot be serialized.
Source§

fn deserialize(buffer: &[u8]) -> VortexResult<Self::Metadata>

Deserialize metadata from a byte buffer.
Source§

fn build( &self, dtype: &DType, len: usize, metadata: &Self::Metadata, _buffers: &[BufferHandle], children: &dyn ArrayChildren, ) -> VortexResult<FoRArray>

Build an array from components. Read more
Source§

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

Attempt to perform a reduction of the parent of this array. Read more
Source§

fn execute( array: &Self::Array, ctx: &mut ExecutionCtx, ) -> Result<Vector, VortexError>

Execute this array to produce a Vector. Read more
Source§

fn execute_parent( array: &Self::Array, parent: &Arc<dyn Array>, child_idx: usize, ctx: &mut ExecutionCtx, ) -> Result<Option<Vector>, VortexError>

Attempt to execute the parent of this array to produce a Vector. Read more
Source§

fn reduce(array: &Self::Array) -> Result<Option<Arc<dyn Array>>, VortexError>

Attempt to reduce the array to a more simple representation. Read more
Source§

impl ValidityChild<FoRVTable> for FoRVTable

Source§

impl VisitorVTable<FoRVTable> for FoRVTable

Source§

fn visit_buffers(_array: &FoRArray, _visitor: &mut dyn ArrayBufferVisitor)

Visit the buffers of the array.
Source§

fn visit_children(array: &FoRArray, visitor: &mut dyn ArrayChildVisitor)

Visit the children of the array.
Source§

fn nbuffers(array: &<V as VTable>::Array) -> usize

Count the number of buffers in the array.
Source§

fn nchildren(array: &<V as VTable>::Array) -> usize

Count the number of children in the array.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<V> ArrayVTableExt for V
where V: VTable,

Source§

fn as_vtable(&'static self) -> ArrayVTable

Wraps the vtable into an ArrayVTable by static reference.
Source§

fn into_vtable(self) -> ArrayVTable

Wraps the vtable into an ArrayVTable by owned reference.
Source§

fn to_vtable(&self) -> ArrayVTable
where V: Clone,

Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> Conv for T

Source§

fn conv<T>(self) -> T
where Self: Into<T>,

Converts self into T using Into<T>. Read more
Source§

impl<T> FmtForward for T

Source§

fn fmt_binary(self) -> FmtBinary<Self>
where Self: Binary,

Causes self to use its Binary implementation when Debug-formatted.
Source§

fn fmt_display(self) -> FmtDisplay<Self>
where Self: Display,

Causes self to use its Display implementation when Debug-formatted.
Source§

fn fmt_lower_exp(self) -> FmtLowerExp<Self>
where Self: LowerExp,

Causes self to use its LowerExp implementation when Debug-formatted.
Source§

fn fmt_lower_hex(self) -> FmtLowerHex<Self>
where Self: LowerHex,

Causes self to use its LowerHex implementation when Debug-formatted.
Source§

fn fmt_octal(self) -> FmtOctal<Self>
where Self: Octal,

Causes self to use its Octal implementation when Debug-formatted.
Source§

fn fmt_pointer(self) -> FmtPointer<Self>
where Self: Pointer,

Causes self to use its Pointer implementation when Debug-formatted.
Source§

fn fmt_upper_exp(self) -> FmtUpperExp<Self>
where Self: UpperExp,

Causes self to use its UpperExp implementation when Debug-formatted.
Source§

fn fmt_upper_hex(self) -> FmtUpperHex<Self>
where Self: UpperHex,

Causes self to use its UpperHex implementation when Debug-formatted.
Source§

fn fmt_list(self) -> FmtList<Self>
where &'a Self: for<'a> IntoIterator,

Formats each item in a sequence. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Pipe for T
where T: ?Sized,

Source§

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

Pipes by value. This is generally the method you want to use. Read more
Source§

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

Borrows self and passes that borrow into the pipe function. Read more
Source§

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

Mutably borrows self and passes that borrow into the pipe function. Read more
Source§

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

Borrows self, then passes self.borrow() into the pipe function. Read more
Source§

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.borrow_mut() into the pipe function. Read more
Source§

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

Borrows self, then passes self.as_ref() into the pipe function.
Source§

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.as_mut() into the pipe function.
Source§

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

Borrows self, then passes self.deref() into the pipe function.
Source§

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.deref_mut() into the pipe function.
Source§

impl<T> SessionVar for T
where T: Send + Sync + Debug + 'static,

Source§

fn as_any(&self) -> &(dyn Any + 'static)

Source§

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Source§

impl<T> Tap for T

Source§

fn tap(self, func: impl FnOnce(&Self)) -> Self

Immutable access to a value. Read more
Source§

fn tap_mut(self, func: impl FnOnce(&mut Self)) -> Self

Mutable access to a value. Read more
Source§

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Immutable access to the Borrow<B> of a value. Read more
Source§

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Mutable access to the BorrowMut<B> of a value. Read more
Source§

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Immutable access to the AsRef<R> view of a value. Read more
Source§

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Mutable access to the AsMut<R> view of a value. Read more
Source§

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Immutable access to the Deref::Target of a value. Read more
Source§

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Mutable access to the Deref::Target of a value. Read more
Source§

fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self

Calls .tap() only in debug builds, and is erased in release builds.
Source§

fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self

Calls .tap_mut() only in debug builds, and is erased in release builds.
Source§

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Calls .tap_borrow() only in debug builds, and is erased in release builds.
Source§

fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Calls .tap_borrow_mut() only in debug builds, and is erased in release builds.
Source§

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Calls .tap_ref() only in debug builds, and is erased in release builds.
Source§

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Calls .tap_ref_mut() only in debug builds, and is erased in release builds.
Source§

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Calls .tap_deref() only in debug builds, and is erased in release builds.
Source§

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Calls .tap_deref_mut() only in debug builds, and is erased in release builds.
Source§

impl<T> TryConv for T

Source§

fn try_conv<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

Attempts to convert self into T using TryInto<T>. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,