Struct JoinOperator 

pub struct JoinOperator {
    pub kind: JoinOperatorKind,
    pub runtime: Option<Arc<ExecutionRuntime>>,
    pub output_layout: Arc<SlotLayout>,
    pub config: OperatorConfig,
}

Join operator.

Wraps JoinOperatorKind with the runtime context injected at open(). Lifecycle state is owned exclusively by the executor; operators never write it.

Fields

kind: JoinOperatorKind

runtime: Option<Arc<ExecutionRuntime>>

output_layout: Arc<SlotLayout>

config: OperatorConfig

Implementations

impl JoinOperator

pub fn new(kind: JoinOperatorKind, output_layout: Arc<SlotLayout>) -> Self

pub fn inject_context( &mut self, runtime: Option<&Arc<ExecutionRuntime>>, config: OperatorConfig, )

Inject the runtime and execution config (called once by the executor before this operator produces any data).

pub fn from_spec( spec: &JoinSpec, memory_budget: &MemoryBudget, output_layout: Arc<SlotLayout>, ) -> Self

pub fn memory_tracker(&self) -> &MemoryTracker

pub fn open( &mut self, left: &mut StreamingExecutor, right: &mut StreamingExecutor, ) -> Result<(), QueryError>

pub fn next( &mut self, left: &mut StreamingExecutor, right: &mut StreamingExecutor, ) -> Result<Option<DataChunk>, QueryError>

pub fn stop(&mut self) -> Result<(), QueryError>

pub fn reset( &mut self, left: &mut StreamingExecutor, right: &mut StreamingExecutor, ) -> Result<bool, QueryError>

Reset per-run join state (hash tables, buffered sides, phase flags) and rewind both inputs so the join re-produces the same result set.

pub fn close(&mut self) -> Result<(), QueryError>

pub fn spill_with_manager( &mut self, sm: &Arc<SpillManager>, ) -> Result<(), QueryError>

Spill the hash join build side to partitioned runs.

Only effective during the build phase (before build_done): buffered build rows are re-partitioned to disk and the remaining build input is routed straight to the spill writers by the build loop. Once the probe phase has started the in-memory table must stay resident and this is a no-op; other join kinds keep their budget-failure semantics.

pub fn spilled_bytes(&self) -> u64

pub fn spill_count(&self) -> u64

pub fn spilled_rows(&self) -> u64

Trait Implementations

impl Debug for JoinOperator

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

Formats the value using the given formatter.