Enum datafusion_physical_plan::execution_plan::ExecutionMode

pub enum ExecutionMode {
    Bounded,
    Unbounded,
    PipelineBreaking,
}

Describes the execution mode of an operator’s resulting stream with respect to its size and behavior. There are three possible execution modes: Bounded, Unbounded and PipelineBreaking.

Variants

Bounded

Represents the mode where generated stream is bounded, e.g. finite.

Unbounded

Represents the mode where generated stream is unbounded, e.g. infinite. Even though the operator generates an unbounded stream of results, it works with bounded memory and execution can still continue successfully.

The stream that results from calling execute on an ExecutionPlan that is Unbounded will never be done (return None), except in case of error.

PipelineBreaking

Represents the mode where some of the operator’s input stream(s) are unbounded; however, the operator cannot generate streaming results from these streaming inputs. In this case, the execution mode will be pipeline breaking, e.g. the operator requires unbounded memory to generate results.

Implementations

impl ExecutionMode

pub fn is_unbounded(&self) -> bool

Check whether the execution mode is unbounded or not.

pub fn pipeline_friendly(&self) -> bool

Check whether the execution is pipeline friendly. If so, operator can execute safely.

Trait Implementations

impl Clone for ExecutionMode

fn clone(&self) -> ExecutionMode

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutionMode

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

Formats the value using the given formatter.

impl PartialEq for ExecutionMode

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for ExecutionMode

impl StructuralPartialEq for ExecutionMode