Struct AsyncMapper 

pub struct AsyncMapper {
    pub async_exprs: Vec<Arc<AsyncFuncExpr>>,
    /* private fields */
}

Maps async_expressions to new columns

The output of the async functions are appended, in order, to the end of the input schema

Fields

async_exprs: Vec<Arc<AsyncFuncExpr>>

the expressions to map

Implementations

impl AsyncMapper

pub fn new(num_input_columns: usize) -> Self

pub fn is_empty(&self) -> bool

pub fn next_column_name(&self) -> String

pub fn find_references( &mut self, physical_expr: &Arc<dyn PhysicalExpr>, schema: &Schema, ) -> Result<()>

Finds any references to async functions in the expression and adds them to the map

pub fn map_expr( &self, expr: Arc<dyn PhysicalExpr>, ) -> Transformed<Arc<dyn PhysicalExpr>>

If the expression matches any of the async functions, return the new column

pub fn output_column(&self, idx: usize) -> Arc<dyn PhysicalExpr>

return the output column for the async function at index idx

Trait Implementations

impl Debug for AsyncMapper

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

Formats the value using the given formatter.