Struct ExecutionPlanDecodeCtx 

pub struct ExecutionPlanDecodeCtx<'a> { /* private fields */ }

Available on crate feature proto only.

Context handed to a plan’s try_from_proto associated function.

Provides the primitives a plan needs to deserialize its children and expressions without naming datafusion-proto.

Implementations

impl<'a> ExecutionPlanDecodeCtx<'a>

pub fn new(decoder: &'a dyn ExecutionPlanDecode) -> Self

Create a new decode context wrapping an [ExecutionPlanDecode] implementation (supplied by datafusion-proto).

pub fn decode_child( &self, node: &PhysicalPlanNode, ) -> Result<Arc<dyn ExecutionPlan>>

Deserialize a single child plan.

pub fn decode_child_with_scalar_subquery_results( &self, node: &PhysicalPlanNode, results: ScalarSubqueryResults, ) -> Result<Arc<dyn ExecutionPlan>>

Deserialize a child plan with results active for scalar subquery expressions in that plan’s subtree.

pub fn decode_required_child( &self, node: Option<&PhysicalPlanNode>, plan_name: &str, field: &str, ) -> Result<Arc<dyn ExecutionPlan>>

Deserialize a required child plan, producing a uniform “missing required field” error when the optional wire field is absent.

pub fn decode_expr( &self, node: &PhysicalExprNode, input_schema: &Schema, ) -> Result<Arc<dyn PhysicalExpr>>

Deserialize a physical expression against input_schema.

pub fn decode_required_expr( &self, node: Option<&PhysicalExprNode>, input_schema: &Schema, plan_name: &str, field: &str, ) -> Result<Arc<dyn PhysicalExpr>>

Deserialize a required physical expression against input_schema.

pub fn task_ctx(&self) -> &TaskContext

The session task context (function registry + session config). Never exposes the proto extension codec.

pub fn decode_udf( &self, name: &str, payload: Option<&[u8]>, ) -> Result<Arc<ScalarUDF>>

Reconstruct a scalar UDF from its name and optional payload. The lookup-order policy is owned by datafusion-proto; no proto types cross this boundary.

pub fn decode_udaf( &self, name: &str, payload: Option<&[u8]>, ) -> Result<Arc<AggregateUDF>>

Reconstruct an aggregate UDF from its name and optional payload.

pub fn decode_udwf( &self, name: &str, payload: Option<&[u8]>, ) -> Result<Arc<WindowUDF>>

Reconstruct a window UDF from its name and optional payload.

pub fn expr_ctx<'s>( &'s self, input_schema: &'s Schema, ) -> PhysicalExprDecodeCtx<'s>

An expression-level decode context backed by this plan context, bound to input_schema.

The decode counterpart of ExecutionPlanEncodeCtx::expr_ctx, for calling conversions such as Partitioning::try_from_proto.

Trait Implementations

impl PhysicalExprDecode for ExecutionPlanDecodeCtx<'_>

Lets ExecutionPlanDecodeCtx back a PhysicalExprDecodeCtx, so expression-level conversions can be reused from plan hooks.

fn decode( &self, node: &PhysicalExprNode, schema: &Schema, ) -> Result<Arc<dyn PhysicalExpr>>

Decode a proto node into a concrete PhysicalExpr. The schema is passed alongside so implementations can support recursive children and rebind the context per call (e.g. for nested plans).