Struct QueryInvocation 

pub struct QueryInvocation { /* private fields */ }

One executable invocation of a reusable validated plan.

The invocation carries values and an operation; the plan carries all reusable structure. Binding is by exact plan fingerprint, so a plan edit invalidates every outstanding invocation instead of silently reshaping it.

Implementations

impl QueryInvocation

pub fn new( plan: &QueryPlan, operation: QueryOperation, inputs: Vec<InputRow>, ) -> Result<Self, Diagnostic>

Validate one rectangular input batch against its exact plan.

pub fn inputs(&self) -> &[InputRow]

Return the rectangular validated input rows.

pub const fn operation(&self) -> QueryOperation

Return the requested operation.

pub const fn plan_fingerprint(&self) -> &QueryPlanFingerprint

Return the exact plan fingerprint this invocation binds.

pub fn binds(&self, plan: &QueryPlan) -> Result<bool, Diagnostic>

Return whether this invocation still binds the supplied plan.

pub fn transport_capabilities(&self) -> CapabilitySet

Return capabilities this invocation’s transport requires beyond the plan’s own.

A multi-row input batch rides the native given transport. A single row with an absent optional cell also requires given, because inline literal substitution has no absence spelling. Datetime-tz inputs use given at every cardinality so named and fixed/second-offset values have one exact lowering. Both client preflight and executor admission check this set against the advertisement so untransportable invocations fail before any I/O or provider resource.

Trait Implementations

impl Clone for QueryInvocation

fn clone(&self) -> QueryInvocation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueryInvocation

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

Formats the value using the given formatter.

impl Eq for QueryInvocation

impl PartialEq for QueryInvocation

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for QueryInvocation

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 QueryInvocation