Trait FlowPlanner 

pub trait FlowPlanner {
    type Input;
    type Output;
    type Error;

    // Required methods
    fn create_execution_plan(
        &self,
        input: Self::Input,
    ) -> Result<Self::Output, Self::Error>;
    fn optimize_plan(
        &self,
        plan: Self::Output,
    ) -> Result<Self::Output, Self::Error>;
}

流程编排器接口

Required Associated Types

type Input

type Output

type Error

Required Methods

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

创建执行计划

fn optimize_plan(&self, plan: Self::Output) -> Result<Self::Output, Self::Error>

优化执行计划

Dyn Compatibility

This trait is dyn compatible.

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

Implementors

impl FlowPlanner for EnhancedFlowOrchestrator

type Input = (Vec<ExecutionNode>, HashMap<String, Value>, HashMap<String, Value>, String, String)

type Output = ExecutionPlan

type Error = Error