Trait AsyncExpression 

pub trait AsyncExpression: ExpressionInfo {
    // Required method
    fn eval_row<'a>(
        &'a self,
        input: &'a OwnedRow,
    ) -> impl Future<Output = Result<Datum>> + Send + 'a;

    // Provided methods
    fn eval<'a>(
        &'a self,
        input: &'a DataChunk,
    ) -> impl Future<Output = Result<ArrayRef>> + Send + 'a { ... }
    fn eval_v2<'a>(
        &'a self,
        input: &'a DataChunk,
    ) -> impl Future<Output = Result<ValueImpl>> + Send + 'a { ... }
}

Interface of an asynchronous expression.

Required Methods

fn eval_row<'a>( &'a self, input: &'a OwnedRow, ) -> impl Future<Output = Result<Datum>> + Send + 'a

Evaluate the expression in row-based execution. Returns a nullable scalar.

Provided Methods

fn eval<'a>( &'a self, input: &'a DataChunk, ) -> impl Future<Output = Result<ArrayRef>> + Send + 'a

Evaluate the expression in vectorized execution. Returns an array.

The default implementation calls eval_v2 and always converts the result to an array.

fn eval_v2<'a>( &'a self, input: &'a DataChunk, ) -> impl Future<Output = Result<ValueImpl>> + Send + 'a

Evaluate the expression in vectorized execution. Returns a value that can be either an array, or a scalar if all values in the array are the same.

The default implementation calls eval and puts the result into the Array variant.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl AsyncExpression for Arc<dyn AsyncDynExpression>

async fn eval(&self, input: &DataChunk) -> Result<ArrayRef>

async fn eval_v2(&self, input: &DataChunk) -> Result<ValueImpl>

async fn eval_row(&self, input: &OwnedRow) -> Result<Datum>

Implementors

impl AsyncExpression for BoxedExpression

impl AsyncExpression for UserDefinedFunction

impl<E, R> AsyncExpression for NonStrict<E, R>

where E: AsyncExpression, R: EvalErrorReport,

impl<E: AsyncExpression> AsyncExpression for BinaryShortCircuitExpression<E>

impl<E: AsyncExpression> AsyncExpression for Checked<E>

impl<E: AsyncExpression> AsyncExpression for SomeAllExpression<E>

impl<E> AsyncExpression for Strict<E>

where E: AsyncExpression,