Struct HashJoinBuffering 

pub struct HashJoinBuffering {}

Looks for all the HashJoinExecs in the plan and places a BufferExec node with the configured capacity in the probe side:

           ┌───────────────────┐
           │   HashJoinExec    │
           └─────▲────────▲────┘
         ┌───────┘        └─────────┐
         │                          │
┌────────────────┐         ┌─────────────────┐
│   Build side   │       + │   BufferExec    │
└────────────────┘         └────────▲────────┘
                                    │
                           ┌────────┴────────┐
                           │   Probe side    │
                           └─────────────────┘

Which allows eagerly pulling it even before the build side has completely finished.

Implementations

impl HashJoinBuffering

pub fn new() -> Self

Trait Implementations

impl Debug for HashJoinBuffering

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

Formats the value using the given formatter.

impl Default for HashJoinBuffering

fn default() -> HashJoinBuffering

Returns the “default value” for a type.

impl PhysicalOptimizerRule for HashJoinBuffering

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

Rewrite plan to an optimized form.

fn name(&self) -> &str

A human readable name for this optimizer rule

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.

fn optimize_with_context( &self, plan: Arc<dyn ExecutionPlan>, context: &dyn PhysicalOptimizerContext, ) -> Result<Arc<dyn ExecutionPlan>>

Rewrite plan with access to extended context (statistics registry, etc.).