Struct mz_repr::RowPacker

source ·
pub struct RowPacker<'a> { /* private fields */ }
Expand description

Packs datums into a Row.

Creating a RowPacker via Row::packer starts a packing operation on the row. A packing operation always starts from scratch: the existing contents of the underlying row are cleared.

To complete a packing operation, drop the RowPacker.

Implementations§

source§

impl RowPacker<'_>

source

pub fn for_existing_row(row: &mut Row) -> RowPacker<'_>

Constructs a row packer that will pack additional datums into the provided row.

This function is intentionally somewhat inconvenient to call. You usually want to call Row::packer instead to start packing from scratch.

source

pub fn push<'a, D>(&mut self, datum: D)
where D: Borrow<Datum<'a>>,

Extend an existing Row with a Datum.

source

pub fn extend<'a, I, D>(&mut self, iter: I)
where I: IntoIterator<Item = D>, D: Borrow<Datum<'a>>,

Extend an existing Row with additional Datums.

source

pub fn try_extend<'a, I, E, D>(&mut self, iter: I) -> Result<(), E>
where I: IntoIterator<Item = Result<D, E>>, D: Borrow<Datum<'a>>,

Extend an existing Row with additional Datums.

In the case the iterator produces an error, the pushing of datums in terminated and the error returned. The Row will be incomplete, but it will be safe to read datums from it.

source

pub fn extend_by_row(&mut self, row: &Row)

Appends the datums of an entire Row.

source

pub unsafe fn extend_by_slice_unchecked(&mut self, data: &[u8])

Appends the slice of data representing an entire Row. The data is not validated.

§Safety

The requirements from Row::from_bytes_unchecked apply here, too: This method relies on data being an appropriate row encoding, and can result in unsafety if this is not the case.

source

pub fn push_list_with<F, R>(&mut self, f: F) -> R
where F: FnOnce(&mut RowPacker<'_>) -> R,

Pushes a DatumList that is built from a closure.

The supplied closure will be invoked once with a Row that can be used to populate the list. It is valid to call any method on the RowPacker except for RowPacker::clear, RowPacker::truncate, or RowPacker::truncate_datums.

Returns the value returned by the closure, if any.

let mut row = Row::default();
row.packer().push_list_with(|row| {
    row.push(Datum::String("age"));
    row.push(Datum::Int64(42));
});
assert_eq!(
    row.unpack_first().unwrap_list().iter().collect::<Vec<_>>(),
    vec![Datum::String("age"), Datum::Int64(42)],
);
source

pub fn push_dict_with<F, R>(&mut self, f: F) -> R
where F: FnOnce(&mut RowPacker<'_>) -> R,

Pushes a DatumMap that is built from a closure.

The supplied closure will be invoked once with a Row that can be used to populate the dict.

The closure must alternate pushing string keys and arbitrary values, otherwise reading the dict will cause a panic.

The closure must push keys in ascending order, otherwise equality checks on the resulting Row may be wrong and reading the dict IN DEBUG MODE will cause a panic.

The closure must not call RowPacker::clear, RowPacker::truncate, or RowPacker::truncate_datums.

§Example
let mut row = Row::default();
row.packer().push_dict_with(|row| {

    // key
    row.push(Datum::String("age"));
    // value
    row.push(Datum::Int64(42));

    // key
    row.push(Datum::String("name"));
    // value
    row.push(Datum::String("bob"));
});
assert_eq!(
    row.unpack_first().unwrap_map().iter().collect::<Vec<_>>(),
    vec![("age", Datum::Int64(42)), ("name", Datum::String("bob"))]
);
source

pub fn push_array<'a, I, D>( &mut self, dims: &[ArrayDimension], iter: I ) -> Result<(), InvalidArrayError>
where I: IntoIterator<Item = D>, D: Borrow<Datum<'a>>,

Convenience function to construct an array from an iter of Datums.

Returns an error if the number of elements in iter does not match the cardinality of the array as described by dims, or if the number of dimensions exceeds MAX_ARRAY_DIMENSIONS. If an error occurs, the packer’s state will be unchanged.

source

pub fn push_list<'a, I, D>(&mut self, iter: I)
where I: IntoIterator<Item = D>, D: Borrow<Datum<'a>>,

Convenience function to push a DatumList from an iter of Datums

See RowPacker::push_dict_with if you need to be able to handle errors

source

pub fn push_dict<'a, I, D>(&mut self, iter: I)
where I: IntoIterator<Item = (&'a str, D)>, D: Borrow<Datum<'a>>,

Convenience function to push a DatumMap from an iter of (&str, Datum) pairs

source

pub fn push_range<'a>( &mut self, range: Range<Datum<'a>> ) -> Result<(), InvalidRangeError>

Pushes a Datum::Range derived from the Range<Datum<'a>.

§Panics
  • If lower and upper express finite values and they are datums of different types.
  • If lower or upper express finite values and are equal to Datum::Null. To handle Datum::Null properly, use RangeBound::new.
§Notes
  • This function canonicalizes the range before pushing it to the row.
  • Prefer this function over push_range_with because of its canonicaliztion.
  • Prefer creating RangeBounds using RangeBound::new, which handles Datum::Null in a SQL-friendly way.
source

pub fn push_range_with<L, U, E>( &mut self, lower: RangeLowerBound<L>, upper: RangeUpperBound<U> ) -> Result<(), E>
where L: FnOnce(&mut RowPacker<'_>) -> Result<(), E>, U: FnOnce(&mut RowPacker<'_>) -> Result<(), E>, E: From<InvalidRangeError>,

Pushes a DatumRange built from the specified arguments.

§Warning

Unlike push_range, push_range_with does not canonicalize its inputs. Consequentially, this means it’s possible to generate ranges that will not reflect the proper ordering and equality.

§Panics
  • If lower or upper expresses a finite value and does not push exactly one value into the RowPacker.
  • If lower and upper express finite values and they are datums of different types.
  • If lower or upper express finite values and push Datum::Null.
§Notes
  • Prefer push_range_with over this function. This function should be used only when you are not pushing Datums to the inner row.
  • Range encoding is [<flag bytes>,<lower>?,<upper>?], where lower and upper are optional, contingent on the flag value expressing an empty range (where neither will be present) or infinite bounds (where each infinite bound will be absent).
  • To push an emtpy range, use push_range using Range { inner: None }.
source

pub fn clear(&mut self)

Clears the contents of the packer without de-allocating its backing memory.

source

pub unsafe fn truncate(&mut self, pos: usize)

Truncates the underlying storage to the specified byte position.

§Safety

pos MUST specify a byte offset that lies on a datum boundary. If pos specifies a byte offset that is within a datum, the row packer will produce an invalid row, the unpacking of which may trigger undefined behavior!

To find the byte offset of a datum boundary, inspect the packer’s byte length by calling packer.data().len() after pushing the desired number of datums onto the packer.

source

pub fn truncate_datums(&mut self, n: usize)

Truncates the underlying row to contain at most the first n datums.

source

pub fn byte_len(&self) -> usize

Returns the total amount of bytes used by the underlying row.

Trait Implementations§

source§

impl<'a> Debug for RowPacker<'a>

source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<'a> Freeze for RowPacker<'a>

§

impl<'a> RefUnwindSafe for RowPacker<'a>

§

impl<'a> Send for RowPacker<'a>

§

impl<'a> Sync for RowPacker<'a>

§

impl<'a> Unpin for RowPacker<'a>

§

impl<'a> !UnwindSafe for RowPacker<'a>

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<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, U> CastInto<U> for T
where U: CastFrom<T>,

source§

fn cast_into(self) -> U

Performs the cast.
source§

impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
where R: Region<Index = (usize, usize)>, O: OffsetContainer<usize>, T: CopyOnto<R>,

source§

fn copy_onto( self, target: &mut ConsecutiveOffsetPairs<R, O> ) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index

Copy self into the target container, returning an index that allows to look up the corresponding read item.
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> FutureExt for T

source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
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> IntoRequest<T> for T

source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
source§

impl<T, U> OverrideFrom<Option<&T>> for U
where U: OverrideFrom<T>,

source§

fn override_from(self, layer: &Option<&T>) -> U

Override the configuration represented by Self with values from the given layer.
source§

impl<T> Pointable for T

source§

const ALIGN: usize = _

The alignment of pointer.
§

type Init = T

The type for initializers.
source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
source§

impl<P, R> ProtoType<R> for P
where R: RustType<P>,

source§

impl<R, T> PushInto<FlatStack<R>> for T
where R: Region + Clone + 'static, T: CopyOnto<R>,

source§

fn push_into(self, target: &mut FlatStack<R>)

Push self into the target container.
source§

impl<T> PushInto<Vec<T>> for T

source§

fn push_into(self, target: &mut Vec<T>)

Push self into the target container.
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

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

§

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>,

§

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<V, T> VZip<V> for T
where V: MultiLane<T>,

source§

fn vzip(self) -> V

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,