Method call_with_args

datafusion/ffi/src/udtf.rs:276–295

(&self, args: TableFunctionArgs)

impl TableFunctionImpl for ForeignTableFunction {
    fn call_with_args(&self, args: TableFunctionArgs) -> Result<Arc<dyn TableProvider>> {
        let session = FFI_SessionRef::new(
            args.session(),
            self.0.runtime(),
            self.0.logical_codec.clone(),
        );
        let codec: Arc<dyn LogicalExtensionCodec> = (&self.0.logical_codec).into();
        let expr_list = LogicalExprList {
            expr: serialize_exprs(args.exprs(), codec.as_ref())?,
        };
        let filters_serialized = expr_list.encode_to_vec().into_iter().collect();

        let table_provider =
            unsafe { (self.0.call_with_args)(&self.0, filters_serialized, session) };

        let table_provider = df_result!(table_provider)?;
        let table_provider: Arc<dyn TableProvider> = (&table_provider).into();

        Ok(table_provider)
    }

    fn call(&self, args: &[datafusion_expr::Expr]) -> Result<Arc<dyn TableProvider>> {
        let codec: Arc<dyn LogicalExtensionCodec> = (&self.0.logical_codec).into();