Struct MapReduceAgent 

pub struct MapReduceAgent { /* private fields */ }

MapReduce Agent

将任务拆分、并行处理、然后归约结果

示例

let map_reduce = MapReduceAgent::new()
    .with_mapper(|task| {
        // 拆分任务为多个子任务
        task.split('\n').map(|s| s.to_string()).collect()
    })
    .with_worker(worker_agent)
    .with_reducer(reducer_agent);

let result = map_reduce.run("line1\nline2\nline3").await?;

Implementations

impl MapReduceAgent

pub fn new() -> MapReduceAgent

创建新的 MapReduce Agent

pub fn with_mapper<F>(self, f: F) -> MapReduceAgent

where F: Fn(&str) -> Vec<String> + Send + Sync + 'static,

设置 Map 函数

pub fn with_worker(self, agent: Arc<ReActAgent>) -> MapReduceAgent

设置工作 Agent (ReAct)

pub fn with_worker_llm(self, agent: Arc<LLMAgent>) -> MapReduceAgent

设置工作 Agent (LLM)

pub fn with_reducer(self, agent: Arc<ReActAgent>) -> MapReduceAgent

设置 Reduce Agent (ReAct)

pub fn with_reducer_llm(self, agent: Arc<LLMAgent>) -> MapReduceAgent

设置 Reduce Agent (LLM)

pub fn with_concurrency_limit(self, limit: usize) -> MapReduceAgent

设置并行度限制

pub fn with_verbose(self, verbose: bool) -> MapReduceAgent

设置是否详细输出

pub async fn run( &self, input: impl Into<String>, ) -> Result<MapReduceResult, LLMError>

执行 MapReduce

Trait Implementations

impl Default for MapReduceAgent

fn default() -> MapReduceAgent

Returns the “default value” for a type.