Trait SubstraitPlan

pub trait SubstraitPlan {
    type Error: Error;
    type Plan;

    // Required methods
    fn decode<'life0, 'async_trait, B>(
        &'life0 self,
        message: B,
        catalog_list: Arc<dyn CatalogProviderList>,
        state: SessionState,
    ) -> Pin<Box<dyn Future<Output = Result<Self::Plan, Self::Error>> + Send + 'async_trait>>
       where B: 'async_trait + Buf + Send,
             Self: 'async_trait,
             'life0: 'async_trait;
    fn encode(
        &self,
        plan: &Self::Plan,
        serializer: impl SerializerRegistry + 'static,
    ) -> Result<Bytes, Self::Error>;
}

Required Associated Types

type Error: Error

type Plan

Required Methods

fn decode<'life0, 'async_trait, B>( &'life0 self, message: B, catalog_list: Arc<dyn CatalogProviderList>, state: SessionState, ) -> Pin<Box<dyn Future<Output = Result<Self::Plan, Self::Error>> + Send + 'async_trait>>

where B: 'async_trait + Buf + Send, Self: 'async_trait, 'life0: 'async_trait,

fn encode( &self, plan: &Self::Plan, serializer: impl SerializerRegistry + 'static, ) -> Result<Bytes, Self::Error>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl SubstraitPlan for DFLogicalSubstraitConvertor

type Error = Error

type Plan = LogicalPlan