akar-processor 0.2.0

Query processor and execution engine for the Akar embedded graph database
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use crate::physical::types::{OperatorResult, PhysicalOperatorExec};
use akar_common::vector::DataChunk;
use akar_parser::ast::Expression;

pub struct PhysicalStandaloneCall {
    pub function_name: String,
    pub args: Vec<Expression>,
    pub handler: std::sync::Arc<dyn crate::processor::StandaloneCallHandler>,
}

impl PhysicalOperatorExec for PhysicalStandaloneCall {
    fn operator_type(&self) -> &str {
        "standalone_call"
    }

    fn execute(&self, _input: Vec<DataChunk>) -> OperatorResult {
        self.handler.execute_call(&self.function_name, &self.args)
    }
}