如何扁平化Nextflow通道元素中的嵌套元组

解决方案 #

直接使用你验证有效的写法即可实现需求：

original_ch = Channel.from([
   ['a', [[1, 2, 3], [4, 5, 6]]],
   ['b', [[7, 8, 9], [10, 11, 12]]]
])

transformed_ch = original_ch.map{ [it[0], it[1].flatten()] }
transformed_ch.view()

执行后会输出预期的扁平结构：

[a, [1, 2, 3, 4, 5, 6]]
[b, [7, 8, 9, 10, 11, 12]]

为什么第一种写法失败？ #

你尝试的flatten(it[1])写法返回nextflow.extension.OpCall对象，核心原因是：

• flatten()是Nextflow针对通道的操作符，并非Groovy列表的原生方法。直接调用flatten(it[1])时，并没有执行列表扁平化操作，只是创建了一个未绑定的操作符调用实例，因此输出的是该实例的引用，而非目标列表。
• 而it[1].flatten()调用的是Groovy列表原生的flatten()方法，它会直接将嵌套列表展开为一维列表，完全匹配你的需求。

补充说明 #

Nextflow的flatten()通道操作符用于处理通道层面的元素展开（比如将包含列表的通道元素拆分为单个元素的通道），但此场景中你需要处理的是每个通道元素内部的嵌套列表，因此必须使用Groovy列表的原生方法。

内容的提问来源于stack exchange，提问作者ZDZ