Struct PythonLogicalCodec 

pub struct PythonLogicalCodec { /* private fields */ }

LogicalExtensionCodec parked on every SessionContext. Holds the Python-aware encoding hooks for logical-layer types (LogicalPlan, Expr) and delegates everything it does not handle to the composable inner codec — typically DefaultLogicalExtensionCodec, or a downstream FFI codec installed via SessionContext.with_logical_extension_codec(...).

Sitting at the top of the session’s logical codec stack means every serializer that reads session.logical_codec() automatically picks up Python-aware encoding for free.

Implementations

impl PythonLogicalCodec

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

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

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

Toggle inline encoding of Python UDFs. See SessionContext.with_python_udf_inlining (Python) for full behavior and use cases.

Security scope: strict mode (false) narrows only the codec layer — it stops Expr::from_bytes from invoking cloudpickle.loads on the inline DFPY* payload. It does not make pickle.loads(untrusted_bytes) safe; treat every pickle.loads on untrusted input as unsafe regardless of this setting. See docs/source/user-guide/io/distributing_work.rst (Security section) for the full threat model, and Python’s pickle module security warning for why pickle.loads is unsafe in general.

pub fn python_udf_inlining(&self) -> bool

Trait Implementations

impl Debug for PythonLogicalCodec

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

Formats the value using the given formatter.

impl Default for PythonLogicalCodec

fn default() -> Self

Returns the “default value” for a type.

impl LogicalExtensionCodec for PythonLogicalCodec

fn try_decode( &self, buf: &[u8], inputs: &[LogicalPlan], ctx: &TaskContext, ) -> Result<Extension>

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

fn try_decode_table_provider( &self, buf: &[u8], table_ref: &TableReference, schema: SchemaRef, ctx: &TaskContext, ) -> Result<Arc<dyn TableProvider>>

fn try_encode_table_provider( &self, table_ref: &TableReference, node: Arc<dyn TableProvider>, buf: &mut Vec<u8>, ) -> Result<()>

fn try_decode_file_format( &self, buf: &[u8], ctx: &TaskContext, ) -> Result<Arc<dyn FileFormatFactory>>

fn try_encode_file_format( &self, buf: &mut Vec<u8>, node: Arc<dyn FileFormatFactory>, ) -> 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_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>>

fn try_decode_higher_order_function( &self, name: &str, _buf: &[u8], ) -> Result<Arc<HigherOrderUDF>, DataFusionError>

fn try_encode_higher_order_function( &self, _node: &HigherOrderUDF, _buf: &mut Vec<u8>, ) -> Result<(), DataFusionError>