Trait datafusion_execution::registry::SerializerRegistry

source · 
pub trait SerializerRegistry: 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>;
}
Expand description

Serializer and deserializer registry for extensions like UserDefinedLogicalNode.

Required Methods§

source

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.

source

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

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

Implementors§