Skip to main content

akar_processor/physical/write_ops/
standalonecall.rs

1use crate::physical::types::{OperatorResult, PhysicalOperatorExec};
2use akar_common::vector::DataChunk;
3use akar_parser::ast::Expression;
4
5pub struct PhysicalStandaloneCall {
6    pub function_name: String,
7    pub args: Vec<Expression>,
8    pub handler: std::sync::Arc<dyn crate::processor::StandaloneCallHandler>,
9}
10
11impl PhysicalOperatorExec for PhysicalStandaloneCall {
12    fn operator_type(&self) -> &str {
13        "standalone_call"
14    }
15
16    fn execute(&self, _input: Vec<DataChunk>) -> OperatorResult {
17        self.handler.execute_call(&self.function_name, &self.args)
18    }
19}