Struct EnsureCooperative 

pub struct EnsureCooperative {}

EnsureCooperative is a PhysicalOptimizerRule that inspects the physical plan for sub plans that do not participate in cooperative scheduling. The plan is subdivided into sub plans on eager evaluation boundaries. Leaf nodes and eager evaluation roots are checked to see if they participate in cooperative scheduling. Those that do no are wrapped in a CooperativeExec parent.

Implementations

impl EnsureCooperative

pub fn new() -> EnsureCooperative

Trait Implementations

impl Debug for EnsureCooperative

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

Formats the value using the given formatter.

impl Default for EnsureCooperative

fn default() -> EnsureCooperative

Returns the “default value” for a type.

impl PhysicalOptimizerRule for EnsureCooperative

fn name(&self) -> &str

A human readable name for this optimizer rule

fn optimize( &self, plan: Arc<dyn ExecutionPlan>, _config: &ConfigOptions, ) -> Result<Arc<dyn ExecutionPlan>, DataFusionError>

Rewrite plan to an optimized form

fn schema_check(&self) -> bool

A flag to indicate whether the physical planner should validate that the rule will not change the schema of the plan after the rewriting. Some of the optimization rules might change the nullable properties of the schema and should disable the schema check.