Trait datafusion_expr::registry::SerializerRegistry

pub trait SerializerRegistry: Send + Sync {
    // Required methods
    fn serialize_logical_plan(
        &self,
        node: &dyn UserDefinedLogicalNode,
    ) -> Result<Vec<u8>>;
    fn deserialize_logical_plan(
        &self,
        name: &str,
        bytes: &[u8],
    ) -> Result<Arc<dyn UserDefinedLogicalNode>>;
}

Serializer and deserializer registry for extensions like UserDefinedLogicalNode.

Required Methods

fn serialize_logical_plan( &self, node: &dyn UserDefinedLogicalNode, ) -> Result<Vec<u8>>

Serialize this node to a byte array. This serialization should not include input plans.

fn deserialize_logical_plan( &self, name: &str, bytes: &[u8], ) -> Result<Arc<dyn UserDefinedLogicalNode>>

Deserialize user defined logical plan node (UserDefinedLogicalNode) from bytes.

Implementors