Enum RowSource 

pub enum RowSource {
    DocumentPages(DocumentPageSource),
    Query(QuerySource),
}

Source relation of an orchestrated copy or join write.

Variants

DocumentPages(DocumentPageSource)

A plain document scan, read page by page through DocumentOp::MaterializeScan. The B-tree key cursor is stable under concurrent writes, so the read has no row-count bound. The Control Plane applies the WHERE filter, the offset, the limit, and the column map to each page.

Query(QuerySource)

Any other SELECT, lowered by the normal plan converter and read once through the Data Plane dispatch funnel. It has exactly SELECT semantics: engine, filters, ordering, distinct, windows, joins, AS OF, and read policies all come from the normal pipeline, under the normal result-byte budget.

Implementations

impl RowSource

pub fn whole_collection(collection: QualifiedCollection) -> Self

A page source that reads every current row of collection unchanged.

pub fn paged_collection(&self) -> Option<&QualifiedCollection>

The collection a page source scans. None for a query source, whose collections are the ones its plan reads.

pub fn query_plan(&self) -> Option<&PhysicalPlan>

The plan a query source runs. None for a page source.

pub fn label(&self) -> &str

A short label for logs and error messages: the paged collection, or the primary collection of the query plan.

Trait Implementations

impl Clone for RowSource

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RowSource

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RowSource

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'__msgpack_de> FromMessagePack<'__msgpack_de> for RowSource

fn read<R: Read<'__msgpack_de>>(reader: &mut R) -> Result<Self, Error>

where Self: Sized,

Reads the MessagePack representation of this value from the provided reader.

impl PartialEq for RowSource

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for RowSource

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for RowSource

impl ToMessagePack for RowSource

fn write<W: Write>(&self, writer: &mut W) -> Result<(), Error>

Writes the MessagePack representation of this value into the provided writer.

fn write_slice<W>(values: &[Self], writer: &mut W) -> Result<(), Error>

where W: Write, Self: Sized,

Writes the MessagePack representation of a slice of values into the provided writer.

fn size_hint(&self) -> Option<TrustedSizeHint>

Returns a trusted upper bound for the number of bytes written by the next call to Self::write, or None when it cannot be determined cheaply.

fn max_size() -> Option<TrustedSizeHint>

where Self: Sized,

Returns a trusted upper bound valid for every value of this type.