Struct EllaExtensionCodec

pub struct EllaExtensionCodec { /* private fields */ }

Implementations

impl EllaExtensionCodec

pub fn new(cluster: Arc<EllaCluster>) -> EllaExtensionCodec

Trait Implementations

impl Clone for EllaExtensionCodec

fn clone(&self) -> EllaExtensionCodec

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EllaExtensionCodec

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl LogicalExtensionCodec for EllaExtensionCodec

fn try_decode( &self, _buf: &[u8], _inputs: &[LogicalPlan], _ctx: &SessionContext, ) -> Result<Extension, DataFusionError>

fn try_encode( &self, _node: &Extension, _buf: &mut Vec<u8>, ) -> Result<(), DataFusionError>

fn try_decode_table_provider( &self, buf: &[u8], _schema: Arc<Schema>, _ctx: &SessionContext, ) -> Result<Arc<dyn TableProvider>, DataFusionError>

fn try_encode_table_provider( &self, node: Arc<dyn TableProvider>, buf: &mut Vec<u8>, ) -> Result<(), DataFusionError>