如何用Nextflow将元组通道转换为指定格式的元组列表？

问题分析 #

输入通道包含三个长度均为4的列表，以及两个固定数值，需要将相同索引位置的列表元素与固定数值组合，生成4个结构一致的元组。

解决方案代码 #

// 定义输入通道
def tuple_ch = Channel.of([['a','a','a','a'], ['B','B','B','B'], ['m','m','m','m'], 1, 2])

// 处理通道生成目标格式
def processed_ch = tuple_ch.map { list_a, list_b, list_m, num1, num2 ->
    // 转置三个列表，获取同索引位置的元素组合
    [list_a, list_b, list_m].transpose().collect { triplet ->
        // 为每个三元组添加固定数值
        triplet + [num1, num2]
    }
}.flatMap() // 若需将每个元组作为独立通道元素则保留，否则移除

// 验证输出
processed_ch.view()

代码说明 #

1. 解构元组：通过map操作提取输入通道中的三个列表和两个固定数值。
2. 转置列表：利用Groovy的transpose()方法，将三个列表按索引对齐，生成包含4个三元组的列表。
3. 组合元素：对每个三元组添加固定数值num1和num2，形成目标元组结构。
4. 展开列表：使用flatMap()将包含4个元组的列表展开为通道的4个独立元素，适配多数流程的输入需求；若后续流程需要接收完整列表作为输入，可移除flatMap()。

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