Struct ApplyOperator 

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

Apply operator.

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

Fields

kind: ApplyOperatorKind

runtime: Option<Arc<ExecutionRuntime>>

output_layout: Arc<SlotLayout>

config: OperatorConfig

Implementations

impl ApplyOperator

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

pub fn new(kind: ApplyOperatorKind, 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 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 materialized state and rewind both inputs.

Apply/PatternApply/RollUpApply drop their materialized right side so the next run re-pulls it; CorrelatedApply additionally resets its reused sub-executor (nested subqueries reset recursively).

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

Trait Implementations

impl Debug for ApplyOperator

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

Formats the value using the given formatter.