Enum SchedulingType

pub enum SchedulingType {
    NonCooperative,
    Cooperative,
}

Represents whether an operator’s Stream has been implemented to actively cooperate with the Tokio scheduler or not. Please refer to the coop module for more details.

Variants

NonCooperative

The stream generated by execute does not actively participate in cooperative scheduling. This means the implementation of the Stream returned by ExecutionPlan::execute does not contain explicit task budget consumption such as tokio::task::coop::consume_budget.

NonCooperative is the default value and is acceptable for most operators. Please refer to the coop module for details on when it may be useful to use Cooperative instead.

Cooperative

The stream generated by execute actively participates in cooperative scheduling by consuming task budget when it was able to produce a RecordBatch.

Trait Implementations

impl Clone for SchedulingType

fn clone(&self) -> SchedulingType

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SchedulingType

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

Formats the value using the given formatter.

impl PartialEq for SchedulingType

fn eq(&self, other: &SchedulingType) -> 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 SchedulingType

impl Eq for SchedulingType

impl StructuralPartialEq for SchedulingType