Struct Coprocessor

pub struct Coprocessor {
    pub name: String,
    pub deco_args: DecoratorArgs,
    pub arg_types: Vec<Option<AnnotationInfo>>,
    pub return_types: Vec<Option<AnnotationInfo>>,
    pub kwarg: Option<String>,
    pub script: String,
    pub code_obj: Option<CodeObject>,
    pub query_engine: Option<QueryEngineWeakRef>,
    pub backend: BackendType,
}

Fields

name: String

deco_args: DecoratorArgs

arg_types: Vec<Option<AnnotationInfo>>

get from python function args’ annotation, first is type, second is is_nullable

return_types: Vec<Option<AnnotationInfo>>

get from python function returns’ annotation, first is type, second is is_nullable

kwarg: Option<String>

kwargs in coprocessor function’s signature

script: String

store its corresponding script, also skip serde when in cfg(test) to reduce work in compare

code_obj: Option<CodeObject>

query_engine: Option<QueryEngineWeakRef>

backend: BackendType

Use which backend to run this script Ideally in test both backend should be tested, so skip this

Implementations

impl Coprocessor

pub(crate) fn gen_schema(&self, cols: &[VectorRef]) -> Result<SchemaRef>

generate [Schema] according to return names, types, if no annotation the datatypes of the actual columns is used directly

pub(crate) fn check_and_cast_type(&self, cols: &mut [VectorRef]) -> Result<()>

check if real types and annotation types(if have) is the same, if not try cast columns to annotated type

Trait Implementations

impl Clone for Coprocessor

fn clone(&self) -> Coprocessor

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Coprocessor

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

Formats the value using the given formatter.

impl PartialEq for Coprocessor

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for Coprocessor