risingwave_stream::executor::prelude

Trait Row

pub trait Row:
    Sized
    + Debug
    + PartialEq
    + Eq {
Show 16 methods    // Required methods
    fn datum_at(&self, index: usize) -> Option<ScalarRefImpl<'_>>;
    unsafe fn datum_at_unchecked(
        &self,
        index: usize,
    ) -> Option<ScalarRefImpl<'_>>;
    fn len(&self) -> usize;
    fn iter(&self) -> impl Iterator<Item = Option<ScalarRefImpl<'_>>>;

    // Provided methods
    fn is_empty(&self) -> bool { ... }
    fn to_owned_row(&self) -> OwnedRow { ... }
    fn into_owned_row(self) -> OwnedRow { ... }
    fn value_serialize_into(&self, buf: impl BufMut) { ... }
    fn value_serialize(&self) -> Vec<u8> ⓘ { ... }
    fn value_serialize_bytes(&self) -> Bytes { ... }
    fn value_estimate_size(&self) -> usize { ... }
    fn memcmp_serialize_into(&self, serde: &OrderedRowSerde, buf: impl BufMut) { ... }
    fn memcmp_serialize(&self, serde: &OrderedRowSerde) -> Vec<u8> ⓘ { ... }
    fn hash_datums_into<H>(&self, state: &mut H)
       where H: Hasher { ... }
    fn hash<H>(&self, hash_builder: H) -> HashCode<H>
       where H: BuildHasher { ... }
    fn eq(this: &Self, other: impl Row) -> bool { ... }
}

Expand description

The trait for abstracting over a Row-like type.

Required Methods§

fn datum_at(&self, index: usize) -> Option<ScalarRefImpl<'_>>

Returns the DatumRef at the given index.

unsafe fn datum_at_unchecked(&self, index: usize) -> Option<ScalarRefImpl<'_>>

Returns the DatumRef at the given index without bounds checking.

§Safety

Calling this method with an out-of-bounds index is undefined behavior.

fn len(&self) -> usize

Returns the number of datum in the row.

fn iter(&self) -> impl Iterator<Item = Option<ScalarRefImpl<'_>>>

Returns an iterator over the datums in the row, in DatumRef form.

Provided Methods§

fn is_empty(&self) -> bool

Returns true if the row contains no datum.

fn to_owned_row(&self) -> OwnedRow

Converts the row into an OwnedRow.

Prefer into_owned_row if the row is already owned.

fn into_owned_row(self) -> OwnedRow

Consumes self and converts it into an OwnedRow.

fn value_serialize_into(&self, buf: impl BufMut)

Serializes the row with value encoding, into the given buf.

fn value_serialize(&self) -> Vec<u8> ⓘ

Serializes the row with value encoding and returns the bytes.

fn value_serialize_bytes(&self) -> Bytes

Serializes the row with value encoding and returns the bytes.

fn value_estimate_size(&self) -> usize

fn memcmp_serialize_into(&self, serde: &OrderedRowSerde, buf: impl BufMut)

Serializes the row with memcomparable encoding, into the given buf. As each datum may have different order type, a serde should be provided.

fn memcmp_serialize(&self, serde: &OrderedRowSerde) -> Vec<u8> ⓘ

Serializes the row with memcomparable encoding and return the bytes. As each datum may have different order type, a serde should be provided.

fn hash_datums_into<H>(&self, state: &mut H)
where H: Hasher,

Hash the datums of this row into the given hasher.

Implementors should delegate std::hash::Hash::hash to this method.

fn hash<H>(&self, hash_builder: H) -> HashCode<H>
where H: BuildHasher,

Returns the hash code of the row.

fn eq(this: &Self, other: impl Row) -> bool

Determines whether the datums of this row are equal to those of another.

Object Safety§

This trait is not object safe.

Implementations on Foreign Types§

impl<D> Row for &[D]
where D: ToDatumRef,

fn datum_at(&self, index: usize) -> Option<ScalarRefImpl<'_>>

unsafe fn datum_at_unchecked(&self, index: usize) -> Option<ScalarRefImpl<'_>>

fn len(&self) -> usize

fn iter(&self) -> impl Iterator<Item = Option<ScalarRefImpl<'_>>>

impl<D, const N: usize> Row for [D; N]
where D: ToDatumRef,

fn datum_at(&self, index: usize) -> Option<ScalarRefImpl<'_>>

unsafe fn datum_at_unchecked(&self, index: usize) -> Option<ScalarRefImpl<'_>>

fn len(&self) -> usize

fn iter(&self) -> impl Iterator<Item = Option<ScalarRefImpl<'_>>>

impl<D, const N: usize> Row for ArrayVec<[D; N]>
where D: ToDatumRef + Default,

fn datum_at(&self, index: usize) -> Option<ScalarRefImpl<'_>>

unsafe fn datum_at_unchecked(&self, index: usize) -> Option<ScalarRefImpl<'_>>

fn len(&self) -> usize

fn iter(&self) -> impl Iterator<Item = Option<ScalarRefImpl<'_>>>

impl<R1, R2> Row for Either<R1, R2>
where R1: Row, R2: Row,

Implements Row for an either::Either of two different types of rows.

fn datum_at(&self, index: usize) -> Option<ScalarRefImpl<'_>>

unsafe fn datum_at_unchecked(&self, index: usize) -> Option<ScalarRefImpl<'_>>

fn len(&self) -> usize

fn is_empty(&self) -> bool

fn iter(&self) -> impl Iterator<Item = Option<ScalarRefImpl<'_>>>

fn to_owned_row(&self) -> OwnedRow

fn into_owned_row(self) -> OwnedRow

fn value_serialize_into(&self, buf: impl BufMut)

fn value_serialize(&self) -> Vec<u8> ⓘ

fn value_serialize_bytes(&self) -> Bytes

fn memcmp_serialize_into(&self, serde: &OrderedRowSerde, buf: impl BufMut)

fn memcmp_serialize(&self, serde: &OrderedRowSerde) -> Vec<u8> ⓘ

fn hash_datums_into<H>(&self, state: &mut H)
where H: Hasher,

fn hash<H>(&self, hash_builder: H) -> HashCode<H>
where H: BuildHasher,

fn eq(this: &Either<R1, R2>, other: impl Row) -> bool

impl<R> Row for Cow<'_, R>
where R: Row + Clone,

fn datum_at(&self, index: usize) -> Option<ScalarRefImpl<'_>>

unsafe fn datum_at_unchecked(&self, index: usize) -> Option<ScalarRefImpl<'_>>

fn len(&self) -> usize

fn is_empty(&self) -> bool

fn iter(&self) -> impl Iterator<Item = Option<ScalarRefImpl<'_>>>

fn to_owned_row(&self) -> OwnedRow

fn value_serialize_into(&self, buf: impl BufMut)

fn value_serialize(&self) -> Vec<u8> ⓘ

fn memcmp_serialize_into(&self, serde: &OrderedRowSerde, buf: impl BufMut)

fn memcmp_serialize(&self, serde: &OrderedRowSerde) -> Vec<u8> ⓘ

fn hash<H>(&self, hash_builder: H) -> HashCode<H>
where H: BuildHasher,

fn hash_datums_into<H>(&self, state: &mut H)
where H: Hasher,

fn eq(this: &Cow<'_, R>, other: impl Row) -> bool

fn into_owned_row(self) -> OwnedRow

impl<R> Row for Option<R>
where R: Row,

Implements Row for an optional row.

fn datum_at(&self, index: usize) -> Option<ScalarRefImpl<'_>>

unsafe fn datum_at_unchecked(&self, index: usize) -> Option<ScalarRefImpl<'_>>

fn len(&self) -> usize

fn iter(&self) -> impl Iterator<Item = Option<ScalarRefImpl<'_>>>

fn to_owned_row(&self) -> OwnedRow

fn into_owned_row(self) -> OwnedRow

fn value_serialize_into(&self, buf: impl BufMut)

fn memcmp_serialize_into(&self, serde: &OrderedRowSerde, buf: impl BufMut)

impl<R> Row for &R
where R: Row,

fn datum_at(&self, index: usize) -> Option<ScalarRefImpl<'_>>

unsafe fn datum_at_unchecked(&self, index: usize) -> Option<ScalarRefImpl<'_>>

fn len(&self) -> usize

fn is_empty(&self) -> bool

fn iter(&self) -> impl Iterator<Item = Option<ScalarRefImpl<'_>>>

fn to_owned_row(&self) -> OwnedRow

fn value_serialize_into(&self, buf: impl BufMut)

fn value_serialize(&self) -> Vec<u8> ⓘ

fn memcmp_serialize_into(&self, serde: &OrderedRowSerde, buf: impl BufMut)

fn memcmp_serialize(&self, serde: &OrderedRowSerde) -> Vec<u8> ⓘ

fn hash<H>(&self, hash_builder: H) -> HashCode<H>
where H: BuildHasher,

fn hash_datums_into<H>(&self, state: &mut H)
where H: Hasher,

fn eq(this: &&R, other: impl Row) -> bool

impl<R> Row for Box<R>
where R: Row,

fn datum_at(&self, index: usize) -> Option<ScalarRefImpl<'_>>

unsafe fn datum_at_unchecked(&self, index: usize) -> Option<ScalarRefImpl<'_>>

fn len(&self) -> usize

fn is_empty(&self) -> bool

fn iter(&self) -> impl Iterator<Item = Option<ScalarRefImpl<'_>>>

fn to_owned_row(&self) -> OwnedRow

fn value_serialize_into(&self, buf: impl BufMut)

fn value_serialize(&self) -> Vec<u8> ⓘ

fn memcmp_serialize_into(&self, serde: &OrderedRowSerde, buf: impl BufMut)

fn memcmp_serialize(&self, serde: &OrderedRowSerde) -> Vec<u8> ⓘ

fn hash<H>(&self, hash_builder: H) -> HashCode<H>
where H: BuildHasher,

fn hash_datums_into<H>(&self, state: &mut H)
where H: Hasher,

fn eq(this: &Box<R>, other: impl Row) -> bool

fn into_owned_row(self) -> OwnedRow

Implementors§

impl Row for ListRef<'_>

impl Row for Empty

impl Row for OwnedRow

impl Row for RowRef<'_>

impl<'i, R> Row for Project<'i, R>
where R: Row,

impl<D> Row for Once<D>
where D: ToDatumRef,

impl<D> Row for RepeatN<D>
where D: ToDatumRef,

impl<R1, R2> Row for Chain<R1, R2>
where R1: Row, R2: Row,

impl<R> Row for Slice<R>
where R: Row,

impl<R> Row for DefaultOrdered<R>
where R: Row,