Struct ComposedPhysicalExtensionCodec 

pub struct ComposedPhysicalExtensionCodec { /* private fields */ }

A PhysicalExtensionCodec that tries one of multiple inner codecs until one works

Implementations

impl ComposedPhysicalExtensionCodec

pub fn new(codecs: Vec<Arc<dyn PhysicalExtensionCodec>>) -> Self

Trait Implementations

impl Debug for ComposedPhysicalExtensionCodec

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

Formats the value using the given formatter.

impl PhysicalExtensionCodec for ComposedPhysicalExtensionCodec

fn try_decode( &self, buf: &[u8], inputs: &[Arc<dyn ExecutionPlan>], ctx: &TaskContext, ) -> Result<Arc<dyn ExecutionPlan>>

fn try_encode( &self, node: Arc<dyn ExecutionPlan>, buf: &mut Vec<u8>, ) -> Result<()>

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

fn try_encode_udf(&self, node: &ScalarUDF, buf: &mut Vec<u8>) -> Result<()>

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

fn try_encode_udaf(&self, node: &AggregateUDF, buf: &mut Vec<u8>) -> Result<()>

fn try_decode_expr( &self, _buf: &[u8], _inputs: &[Arc<dyn PhysicalExpr>], ) -> Result<Arc<dyn PhysicalExpr>>

fn try_encode_expr( &self, _node: &Arc<dyn PhysicalExpr>, _buf: &mut Vec<u8>, ) -> Result<()>

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

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