如何通过Talend计算单列数据总和并追加到CSV输出行中

你可以根据待处理的CSV文件体量选对应实现方式，不用改原有输入输出的核心配置：

方案一：中小体量CSV优先选（内存聚合，IO开销小） #

• 先在作业全局变量面板新增数值型变量，比如命名为total_sum，类型匹配你要求和的列（Integer/Double按需选），初始值设为0。
• 从你现有的CSV输入组件（tFileInputDelimited）拉两条流：
  • 第一条流接tHashOutput组件，用来把全量原始行暂存到内存缓存，组件不用额外配置，记好缓存的名称就行。
  • 第二条流接tAggregateRow组件：分组列（Group by）留空做全表聚合，在计算规则（Operations）里新增规则，选你要计算的目标列，聚合函数选sum，输出字段命名为calc_total。
• tAggregateRow后面接tSetGlobalVar组件，把聚合得到的calc_total直接赋值给之前创建的total_sum变量。
• 新增tHashInput组件，关联刚才存原始数据的tHashOutput缓存，把全量原始数据读出后接tMap组件：在tMap输出端新增一列存求和结果，列值直接引用全局变量即可，示例写法：(Double)globalMap.get("total_sum")，类型不匹配时按需做强转。把原始需要保留的列、新增的求和列一起映射到tMap输出端。
• tMap输出直接接你原有的CSV输出组件（tFileOutputDelimited），核对好输出列顺序、分隔符配置，运行后每一行末尾都会追加全表指定列的总和值。

方案二：超大CSV适用（无需全量加载到内存） #

• 先单独建一个前置子作业流：用和你现有配置完全一致的tFileInputDelimited读取源CSV，接tAggregateRow按之前的规则算出指定列总和，再接tSetGlobalVar把结果存入total_sum全局变量。
• 用OnSubjobOk触发器把前置求和子作业和你原来的主流程连起来，确保先算完总和再执行主输出流程。
• 在你原有的CSV输入、输出组件中间插入tMap组件，和方案一的配置一致，新增列映射全局变量total_sum后输出到CSV即可。

避坑提醒：不要直接在逐行处理的tJavaRow里写累加逻辑直接输出，这种方式拿到的是逐行累计的中间值，只有最后一行的结果是全量总和，前面所有行的求和值都是错的。
如果你的需求是按字段分组后，把组内总和追加到同组的每一行，只需要在tAggregateRow里添加上对应的分组字段，之后用tMap按分组键把聚合结果和原始流做关联即可，不需要存全局变量。

内容的提问来源于stack exchange，提问作者ⵡⴰⵍⵉⴷ