ApacheBeamFlattenisnottakingdatafromothersPcollection
创始人
2024-09-05 11:01:17
0

在使用Flatten进行多个Pcollection合并时,需确保Pcollection已经被赋值或含有数据。以下是示例代码:

import apache_beam as beam

with beam.Pipeline() as pipeline:
   pcoll1 = pipeline | "Create Pcollection 1" >> beam.Create([1, 2, 3])
   pcoll2 = pipeline | "Create Pcollection 2" >> beam.Create([4, 5, 6])
   merged_pcoll = ((pcoll1, pcoll2) | "Flatten" >> beam.Flatten())
   merged_pcoll | "Print Merged Pcollection" >> beam.Map(print)

在此示例中,我们创建了两个Pcollection,分别包含整数1到3和4到6。然后,我们使用Flatten将两个Pcollection合并成一个Pcollection。最后,我们使用Map函数打印出合并后的Pcollection。

需要注意的是,在Flatten函数之前,每个Pcollection都需要给予赋值或者含有数据。因为Flatten展开所有的输入pcollection ,从而使它们中的所有元素都变为对输出pcollection 的元素的数据点的多次引用。如果没有划分的数据或没有数据,则Flatten函数不会返回任何内容。

使用此代码示例可解决“Apache Beam Flatten is not taking data from others Pcollection”的问题。

相关内容

热门资讯

今日百科!九九山城万州版脚本,... 今日百科!九九山城万州版脚本,wejoker免费脚本,德州教程(有挂工具);九九山城万州版脚本软件透...
今日科普!奇迹脚本辅助,wpk... 今日科普!奇迹脚本辅助,wpk安卓下载辅助,技巧教程(有挂细节);【福星临门,好运相随】;今日科普!...
分享个大家!情怀透明器看手机纸... 分享个大家!情怀透明器看手机纸牌,hhpoker有没有辅助,揭秘教程(有挂分析);暗藏猫腻!情怀透明...
玩家必备攻略!打哈儿辅助软件,... 您好:打哈儿辅助软件这款游戏可以开挂的,确实是有挂的,很多玩家在这款游戏中打牌都会发现很多用户的牌特...
盘点一款!填大坑辅助工具排行,... 盘点一款!填大坑辅助工具排行,wpk刷入池率脚本,大神讲解(揭秘有挂);1.填大坑辅助工具排行 ai...
一起来探讨!决战13水辅助,w... 您好:决战13水辅助这款游戏可以开挂的,确实是有挂的,很多玩家在这款游戏中打牌都会发现很多用户的牌特...
一分钟揭秘!丽水双扣茶苑脚本,... 一分钟揭秘!丽水双扣茶苑脚本,xpoker辅助控制,2025教程(有挂解惑)是一款可以让一直输的玩家...
今日百科!腾讯欢乐卡五星辅助器... 今日百科!腾讯欢乐卡五星辅助器,wepoker安装教程,2025新版(有挂神器)是一款可以让一直输的...
玩家必看科普!微信小程序外辅助... 玩家必看科普!微信小程序外辅助工具,pokernow辅助工具,力荐教程(有挂攻略);1、界面简单,没...
一分钟教会你!授权二厅辅助,w... 《一分钟教会你!授权二厅辅助,wpk有那种辅助吗,黑科技教程(果真有挂)》 授权二厅辅助软件透明挂更...