Method to_bytes

datafusion/proto/src/bytes/mod.rs:78–98

(&self)

impl Serializeable for Expr {
    fn to_bytes(&self) -> Result<Bytes> {
        let mut buffer = BytesMut::new();
        let extension_codec = DefaultLogicalExtensionCodec {};
        let protobuf: protobuf::LogicalExprNode = serialize_expr(self, &extension_codec)
            .map_err(|e| plan_datafusion_err!("Error encoding expr as protobuf: {e}"))?;

        protobuf
            .encode(&mut buffer)
            .map_err(|e| plan_datafusion_err!("Error encoding protobuf as bytes: {e}"))?;

        let bytes: Bytes = buffer.into();

        // The produced byte stream may lead to "recursion limit" errors, see
        // https://github.com/apache/datafusion/issues/3968
        // Until the underlying prost issue ( https://github.com/tokio-rs/prost/issues/736 )
        // is fixed, verify the bytes can be decoded without hitting that limit.
        protobuf::LogicalExprNode::decode(bytes.as_ref())
            .map_err(|e| plan_datafusion_err!("Error decoding expr as protobuf: {e}"))?;

        Ok(bytes)
    }

    fn from_bytes_with_ctx(bytes: &[u8], ctx: &TaskContext) -> Result<Self> {
        let protobuf = protobuf::LogicalExprNode::decode(bytes)