用途:将并行 DAG 分支的输出合并为统一结果,适合在工作流中汇总多个并行节点的产出。
主要能力:包括结果收集(汇总所有并行分支输出、跟踪依赖完成状态、处理失败分支的部分结果)、合并策略(按数据类型选择合并方式)、结果转换(为下游节点格式化、应用模式转换、校验输出结构)以及冲突解决(检测并行输出冲突、应用解决策略、记录解决决策)。
合并模式:并集合并(合并多个来源的独立数据)、交集合并(保留所有分支共有的结果,用于跨分析共识)、优先级合并(取最高优先级分支结果)、加权平均(合并数值或置信度)、深度合并(递归合并对象结构)。冲突策略支持 first-wins、last-wins、highest-wins、lowest-wins、concatenate、error、custom。
使用方式:以聚合配置定义输入来源节点与字段、策略与冲突解决方式、转换步骤(去重、排序、限制)以及输出 schema。可按配置执行聚合并生成包含输入状态、冲突记录、统计信息和输出的聚合报告。部分结果处理可设置最低成功率,低于阈值时抛出错误。
适用场景:并行分析结果汇总、多来源数据收集、分支共识判断、数值评估合并等。
限制:资料未说明具体安装命令、运行平台、依赖版本、性能上限或收费方式,暂未提供。