nextflow - splitCsv 为每一行多次加入通道 nextflow
问题描述
我有一个my_csv.csv
包含三列的 csv 文件,我可以使用它来读取它spliCsv
,如下所示:
csv_ch.splitCsv(header:false,sep:',').map{row->tuple(row[0],row[1],row[2])}.view()
[chr1, 0, 1 10]
[chr1, 1, 10 20]
[chr1, 2, 20 30]
[chr2, 0, 1 10]
[chr2, 1, 10 20]
[chr2, 2, 20 30]
[chr3, 0, 1 10]
[chr3, 1, 10 20]
[chr3, 2, 20 30]
...
我有另一个map_ch
看起来像的频道
map_ch.view()
[chr1,[map1.txt]
chr2,[map2.txt]
chr3,[mp3.txt]
chr4,[mp4.txt]]
……
现在,我想得到:
[chr1, 0, 1 10,[map1.txt]
[chr1, 1, 10 20,[map1.txt]
[chr1, 2, 20 30,[map1.txt]]
[chr2, 0, 1 10,[map2.txt]
[chr2, 1, 10 20,[map2.txt]
[chr2, 2, 20 30,[map2.txt]]
[chr3, 0, 1 10,[map3.txt]]
[chr3, 1, 10 20,[map3.txt]
[chr3, 2, 20 30,[map3.txt]]
如果我使用join
运算符,我只会得到
[chr1, 0, 1 10,[map1.txt]
[chr2, 0, 1 10,[map2.txt]
[chr3, 0, 1 10,[map3.txt]]
这不是我需要的
解决方案
组合运算符具有魔力。
map_ch.combine(csv_ch,by:0)
它给了我我需要的东西。
推荐阅读
- html - 引导导航栏切换不切换
- ms-access - 如何在过滤器中的表字段上使用 nz
- python - 在 tkinter 中旋转带有图像的标签
- python - 经常发邮件
- python - 在烧瓶上上传文件并清理文件
- javascript - Nuxt 运行构建失败,但 dev 很好(处理此文件类型的加载程序)
- python - 如何处理“TypeError: add_all_ta_features() got multiple values for keyword argument 'fillna'”?
- jquery - 将横幅大小从桌面版调整为移动版
- angular - 重新加载页面时忽略ng-deep?
- python - 解释器找不到 Intellij python sdk 资源管理器中显示的 Python 包