Struct DeltaLogicalCodec

pub struct DeltaLogicalCodec {}

Does serde on DeltaTables

Trait Implementations

impl Debug for DeltaLogicalCodec

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

Formats the value using the given formatter.

impl LogicalExtensionCodec for DeltaLogicalCodec

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], _table_ref: &TableReference, _schema: SchemaRef, _ctx: &SessionContext, ) -> Result<Arc<dyn TableProvider>, DataFusionError>

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

fn try_decode_file_format( &self, _buf: &[u8], _ctx: &SessionContext, ) -> Result<Arc<dyn FileFormatFactory>, DataFusionError>

fn try_encode_file_format( &self, _buf: &mut Vec<u8>, _node: Arc<dyn FileFormatFactory>, ) -> Result<(), DataFusionError>

fn try_decode_udf( &self, name: &str, _buf: &[u8], ) -> Result<Arc<ScalarUDF>, DataFusionError>

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

fn try_decode_udaf( &self, name: &str, _buf: &[u8], ) -> Result<Arc<AggregateUDF>, DataFusionError>

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

fn try_decode_udwf( &self, name: &str, _buf: &[u8], ) -> Result<Arc<WindowUDF>, DataFusionError>

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