Struct PythonPhysicalCodec 

pub struct PythonPhysicalCodec { /* private fields */ }

PhysicalExtensionCodec mirror of PythonLogicalCodec parked on the same SessionContext. Carries the Python-aware encoding hooks for physical-layer types (ExecutionPlan, PhysicalExpr) and delegates the rest to inner.

The PhysicalExtensionCodec trait has its own try_encode_udf / try_decode_udf pair distinct from the logical one, so a ScalarUDF referenced inside a physical plan needs Python-aware encoding on this layer too — otherwise a plan with a Python UDF would round-trip at the logical level but break at the physical level. Both layers reuse the shared payload framing ([PY_SCALAR_UDF_FAMILY] et al.) so the wire format is identical.

Implementations

impl PythonPhysicalCodec

pub fn new(inner: Arc<dyn PhysicalExtensionCodec>) -> Self

pub fn inner(&self) -> &Arc<dyn PhysicalExtensionCodec>

pub fn with_python_udf_inlining(self, enabled: bool) -> Self

Toggle inline encoding of Python UDFs on this physical codec.

Mirrors PythonLogicalCodec::with_python_udf_inlining; see that method for the full security and portability discussion.

pub fn python_udf_inlining(&self) -> bool

Trait Implementations

impl Debug for PythonPhysicalCodec

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

Formats the value using the given formatter.

impl Default for PythonPhysicalCodec

fn default() -> Self

Returns the “default value” for a type.

impl PhysicalExtensionCodec for PythonPhysicalCodec

fn try_decode( &self, buf: &[u8], inputs: &[Arc<dyn ExecutionPlan>], ctx: &TaskContext, ) -> Result<Arc<dyn ExecutionPlan>>

fn try_encode( &self, node: Arc<dyn ExecutionPlan>, buf: &mut Vec<u8>, ) -> Result<()>

fn try_encode_udf(&self, node: &ScalarUDF, buf: &mut Vec<u8>) -> Result<()>

fn try_decode_udf(&self, name: &str, buf: &[u8]) -> Result<Arc<ScalarUDF>>

fn try_encode_expr( &self, node: &Arc<dyn PhysicalExpr>, buf: &mut Vec<u8>, ) -> Result<()>

fn try_decode_expr( &self, buf: &[u8], inputs: &[Arc<dyn PhysicalExpr>], ) -> Result<Arc<dyn PhysicalExpr>>

fn try_encode_udaf(&self, node: &AggregateUDF, buf: &mut Vec<u8>) -> Result<()>

fn try_decode_udaf(&self, name: &str, buf: &[u8]) -> Result<Arc<AggregateUDF>>

fn try_encode_udwf(&self, node: &WindowUDF, buf: &mut Vec<u8>) -> Result<()>

fn try_decode_udwf(&self, name: &str, buf: &[u8]) -> Result<Arc<WindowUDF>>