Struct RemotePhysicalCodec 

pub struct RemotePhysicalCodec {
    pub transform_codec: Arc<dyn TransformCodec>,
    pub unparse_codec: Arc<dyn UnparseCodec>,
    pub connection_codec: Arc<dyn ConnectionCodec>,
}

Fields

transform_codec: Arc<dyn TransformCodec>

unparse_codec: Arc<dyn UnparseCodec>

connection_codec: Arc<dyn ConnectionCodec>

Implementations

impl RemotePhysicalCodec

pub fn with_transform_codec( self, transform_codec: impl Into<Arc<dyn TransformCodec>>, ) -> Self

pub fn with_unparse_codec( self, unparse_codec: impl Into<Arc<dyn UnparseCodec>>, ) -> Self

pub fn with_connection_codec( self, connection_codec: impl Into<Arc<dyn ConnectionCodec>>, ) -> Self

impl RemotePhysicalCodec

pub fn new() -> Self

Trait Implementations

impl Debug for RemotePhysicalCodec

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

Formats the value using the given formatter.

impl Default for RemotePhysicalCodec

fn default() -> Self

Returns the “default value” for a type.

impl PhysicalExtensionCodec for RemotePhysicalCodec

fn try_decode( &self, buf: &[u8], inputs: &[Arc<dyn ExecutionPlan>], registry: &dyn FunctionRegistry, ) -> 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>, DataFusionError>

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

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

fn try_encode_expr( &self, _node: &Arc<dyn PhysicalExpr>, _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>