Package com.alibaba.cloud.ai.graph.agent.flow.node

Class EnhancedParallelResultAggregator

java.lang.Object

com.alibaba.cloud.ai.graph.agent.flow.node.EnhancedParallelResultAggregator

All Implemented Interfaces:

NodeAction

public class EnhancedParallelResultAggregator
extends Object
implements NodeAction

Enhanced parallel result aggregator that supports custom merge strategies and concurrency control. This class serves as a bridge between the FlowGraphBuilder and ParallelAgent's merge strategies.

Constructor Summary

Constructors

Constructor	Description
EnhancedParallelResultAggregator(String outputKey, List<BaseAgent> subAgents, Object mergeStrategy, Integer maxConcurrency)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	apply(OverAllState state)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

EnhancedParallelResultAggregator

public EnhancedParallelResultAggregator(String outputKey,
 List<BaseAgent> subAgents,
 Object mergeStrategy,
 Integer maxConcurrency)

Method Details

apply

public Map<String,Object> apply(OverAllState state)
                         throws Exception

Specified by:

apply in interface NodeAction

Throws:

Exception