Struct ScaleUpLeafNodeEvent 

pub struct ScaleUpLeafNodeEvent<'a> {
    pub plan: &'a Arc<dyn ExecutionPlan>,
    pub task_count: usize,
    pub session_config: &'a SessionConfig,
}

Information supplied when a leaf has been assigned its final stage task count.

This event runs after desired task counts from all of the stage’s leaves have been reconciled, so [Self::handle] is the count that the stage will actually use. A handler can use it to replace a leaf with a task-specialized plan, such as a crate::DistributedLeafExec that selects a different input for every task.

Fields

plan: &'a Arc<dyn ExecutionPlan>

The leaf execution plan to replace, if this handler recognizes it.

task_count: usize

The final number of tasks that will execute the leaf’s stage.

session_config: &'a SessionConfig

The session configuration that registered the event handlers and holds query options.

Trait Implementations

impl<'a> Clone for ScaleUpLeafNodeEvent<'a>

fn clone(&self) -> ScaleUpLeafNodeEvent<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Copy for ScaleUpLeafNodeEvent<'a>