pub trait BatchExecution: Send {
// Required method
fn execute<'async_trait>(
self: Box<Self>,
) -> Pin<Box<dyn Future<Output = VortexResult<Canonical>> + Send + 'async_trait>>
where Self: 'async_trait;
}
Expand description
The primary execution trait for operators.
Alternatively, or additionally, operators may choose to implement PipelinedOperator
.