Trait SerializerRegistry

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

Serializer and deserializer registry for extensions like UserDefinedLogicalNode.

Required Methods

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

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>, DataFusionError>

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

Implementors