Enum StreamingEligibility 

pub enum StreamingEligibility {
    Supported {
        source_limits: Vec<SourceLimit>,
    },
    Unsupported {
        subject: PlanSubject,
        reason: StreamingReason,
    },
    RequiresMaterialization {
        subject: PlanSubject,
        bounded_possible: bool,
    },
}

Physical plan compiler and plan node types. Eligibility outcome returned before opening a source.

Variants

Supported

The compiler can construct a bounded source and per-batch pipeline.

Fields

source_limits: Vec<SourceLimit>

Unsupported

No streaming implementation exists for this source or operator.

Fields

subject: PlanSubject

The rejected source or operator.

reason: StreamingReason

Stable reason code.

RequiresMaterialization

The operation is known but needs an explicit bounded materialization algorithm.

Fields

subject: PlanSubject

The rejected operator.

bounded_possible: bool

Whether a bounded materialization implementation is available.

Implementations

impl StreamingEligibility

pub fn into_result(self) -> Result<Vec<SourceLimit>>

Convert a non-supported result to its public preflight error.

Trait Implementations

impl Clone for StreamingEligibility

fn clone(&self) -> StreamingEligibility

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingEligibility

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

Formats the value using the given formatter.

impl Eq for StreamingEligibility

impl PartialEq for StreamingEligibility

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for StreamingEligibility