Struct RowSchema 

pub struct RowSchema { /* private fields */ }

Immutable column layout shared by an operator and all of its batches.

columns are the logical output labels. slots may point into a wider composite physical row after a projection/rename, allowing those operators to change row shape without moving any values.

Implementations

impl RowSchema

pub fn with_typed_outer_scope( input: &Self, outer_columns: &[(String, Option<ColumnType>)], ) -> Self

Overlay a statically typed correlated outer scope. The outer columns remain hidden from schema iteration and star expansion, but both qualified and unqualified lookup aliases retain their declared SQL types for expression binding.

pub fn with_typed_outer_identities( input: &Self, outer_columns: &[(ColumnIdentity, Option<ColumnType>)], ) -> Self

Overlay a correlated outer scope carried as structured identities.

impl RowSchema

pub fn new(columns: Vec<String>) -> Self

pub fn with_types(columns: Vec<String>, types: Vec<Option<ColumnType>>) -> Self

Build a positional schema with statically bound SQL types.

pub fn with_qualified_types( qualifier: &str, columns: Vec<String>, types: Vec<Option<ColumnType>>, ) -> Self

Build a positional schema whose visible columns all belong to one relation qualifier while retaining their public names verbatim.

pub fn with_identities( columns: Vec<String>, identities: Vec<ColumnIdentity>, types: Vec<Option<ColumnType>>, ) -> Self

Build a positional schema from explicit structured identities.

pub fn from_named_columns(columns: Vec<String>) -> Self

Build the lookup semantics of a named compatibility row. An exact bare key in a map is authoritative even when qualified metadata keys share its suffix; physical relational schemas continue to treat multiple visible owners as ambiguous.

pub fn columns(&self) -> &[String]

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn iter(&self) -> Iter<'_, String>

pub fn column_type(&self, logical: usize) -> Option<&ColumnType>

Static SQL type at one logical output position.

pub fn column_types(&self) -> &[Option<ColumnType>]

Static SQL types aligned with Self::columns.

pub fn identities(&self) -> &[ColumnIdentity]

Structured SQL identities aligned with Self::columns.

pub fn has_qualifier(&self, qualifier: &str) -> bool

Whether a visible or hidden lookup identity belongs to qualifier.

pub fn identity(&self, logical: usize) -> Option<&ColumnIdentity>

pub fn public_name(&self, logical: usize) -> Option<&str>

pub fn position(&self, name: &str) -> Option<usize>

pub fn unqualified_position(&self, column: &str) -> Option<usize>

Resolve one visible unqualified SQL identity to its logical position. Ambiguous names deliberately do not select an arbitrary owner.

pub fn qualified_position(&self, qualifier: &str, column: &str) -> Option<usize>

Resolve one visible qualified identity to its logical position.

pub fn physical_width(&self) -> usize

pub fn physical_slot(&self, logical: usize) -> Option<usize>

Resolve one logical output position to its flattened physical slot.

pub fn physical_slot_for_identity( &self, identity: &ColumnIdentity, ) -> Option<usize>

Resolve a structured SQL identity, including a hidden JOIN USING alias, to its flattened physical slot. Ambiguous identities deliberately return None rather than selecting an arbitrary source value.

pub fn type_of(&self, name: &str) -> Option<&ColumnType>

Resolve an unqualified logical identity to its static type.

pub fn qualified_type( &self, qualifier: &str, column: &str, ) -> Option<&ColumnType>

Resolve a qualified logical identity to its static type.

pub fn qualified_star_layout( &self, qualifier: &str, ) -> Vec<(String, usize, Option<ColumnType>)>

Physical projection layout for qualifier.* in relation-column order. Hidden identities introduced by JOIN ... USING remain selectable, so each side’s wildcard retains its own merged-column value.

pub fn qualified_star_position_layout( &self, qualifier: &str, ) -> Vec<(String, Option<usize>, usize, Option<ColumnType>)>

Bound layout for qualifier.*. Visible columns retain their logical positions; hidden aliases such as the suppressed side of JOIN ... USING expose only their physical slot.

pub fn column_is_ambiguous(&self, name: &str) -> bool

pub fn qualified_column_is_ambiguous( &self, qualifier: &str, column: &str, ) -> bool

pub fn select(input: &Self, columns: &[(String, String)]) -> Self

Select and optionally rename logical columns while retaining the child’s physical fragments.

pub fn with_identity_aliases( input: &Self, aliases: &[(ColumnIdentity, usize)], ) -> Self

Add hidden structured lookup identities for existing logical positions.

pub fn append(input: &Self, names: &[String]) -> Self

Append freshly-computed values to an existing physical row. Reusing an existing output name replaces its logical slot just like map insertion.

pub fn append_typed( input: &Self, names: &[(String, Option<ColumnType>)], ) -> Self

Append freshly computed values with static SQL output types.

pub fn join( left: &Self, right: &Self, extra_columns: impl IntoIterator<Item = String>, ) -> Self

Compose two child layouts while retaining duplicate logical labels. Qualified and positional resolution can then distinguish both input slots without copying either value fragment.

pub fn view<'a>(&'a self, row: &'a PhysicalRow) -> PhysicalRowView<'a>

pub fn relayout_physical_row( &self, row: PhysicalRow, target: &Self, ) -> ExecResult<PhysicalRow>

Re-express a row emitted under this schema in target’s complete physical layout without cloning any values. Visible columns are matched by logical position; hidden lookup aliases are matched by their structured identity. This is used when two equivalent operator pipelines expose the same logical row through different physical slot arrangements.

Trait Implementations

impl Clone for RowSchema

fn clone(&self) -> RowSchema

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RowSchema

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

Formats the value using the given formatter.

impl Default for RowSchema

fn default() -> Self

Returns the “default value” for a type.

impl Eq for RowSchema

impl From<Vec<String>> for RowSchema

fn from(columns: Vec<String>) -> Self

Converts to this type from the input type.

impl PartialEq for RowSchema

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for RowSchema