Struct EnhancedTaskExecutor 

pub struct EnhancedTaskExecutor { /* private fields */ }

增强的任务执行器

Implementations

impl EnhancedTaskExecutor

pub fn new() -> Self

创建新的任务执行器

pub fn with_config(config: ExecutorConfig) -> Self

使用配置创建任务执行器

pub async fn execute_plan( &mut self, plan: ExecutionPlan, context: SharedContext, ) -> Result<ExecutionResult>

执行执行计划

pub fn get_stats(&self) -> &ExecutionStats

获取执行统计

Trait Implementations

impl Default for EnhancedTaskExecutor

fn default() -> Self

Returns the “default value” for a type.

impl Executor for EnhancedTaskExecutor

type Input = (ExecutionPlan, Arc<Mutex<FlowContext>>)

type Output = ExecutionResult

type Error = Error

async fn execute( &mut self, input: Self::Input, ) -> Result<Self::Output, Self::Error>

执行输入并返回结果

fn status(&self) -> ExecutorStatus

获取执行器状态

async fn stop(&mut self) -> Result<(), Self::Error>

停止执行器