Struct PythonUDFPayload 

pub struct PythonUDFPayload {
    pub output_type: DataType,
    pub eval_type: i32,
    pub command: Vec<u8>,
    pub python_ver: String,
}

Represents a Python UDF with its serialized command and metadata.

Fields

output_type: DataType

The output data type of the UDF.

eval_type: i32

The evaluation type (e.g., SQL_BATCHED_UDF, SQL_SCALAR_PANDAS_UDF).

command: Vec<u8>

The cloudpickled command bytes: typically cloudpickle.dumps((func, output_type)).

python_ver: String

Python version used for pickling (e.g., “3.9”, “3.11”).

Implementations

impl PythonUDFPayload

pub fn new( output_type: DataType, eval_type: i32, command: Vec<u8>, python_ver: String, ) -> Self

Create a new Python UDF payload.

pub fn to_proto(&self) -> PythonUdf

Convert to a proto PythonUDF message.

Trait Implementations

impl Clone for PythonUDFPayload

fn clone(&self) -> PythonUDFPayload

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PythonUDFPayload

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

Formats the value using the given formatter.

impl PartialEq for PythonUDFPayload

fn eq(&self, other: &PythonUDFPayload) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for PythonUDFPayload