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”的问题。

相关内容

热门资讯

必备教程透视挂方法!澳门永利集... 必备教程透视挂方法!澳门永利集团多功能透视挂方法,澳门永利集团其实是真的有透视挂方法1、许多玩家不知...
查到实测辅助辅助器工具!抚顺麻... 查到实测辅助辅助器工具!抚顺麻将多功能辅助器工具,抚顺麻将一贯是有辅助器工具1)抚顺麻将辅助插件:进...
科技通报透视器脚本!赫麒众游多... 科技通报透视器脚本!赫麒众游多功能透视器脚本,赫麒众游确实有透视器脚本;在进入赫麒众游软件靠谱后,参...
专业讨论作弊器方法!海迅麻将多... 专业讨论作弊器方法!海迅麻将多功能作弊器方法,海迅麻将其实是真的有作弊器方法暗藏猫腻,小编详细说明海...
热点讨论作弊器教程!宁夏麻将多... 热点讨论作弊器教程!宁夏麻将多功能作弊器教程,宁夏麻将都是真的有作弊器教程1、进入游戏-大厅左侧-新...
如何分辨真伪辅助器软件!小闲巴... 如何分辨真伪辅助器软件!小闲巴渝棋牌多功能辅助器软件,小闲巴渝棋牌一贯存在有辅助器软件所有人都在同一...
让我来分享经验透视器app!老... 让我来分享经验透视器app!老友汇多功能透视器app,老友汇总是是真的有透视器app运老友汇辅助工具...
科技揭秘开挂攻略!指尖四川麻将... 科技揭秘开挂攻略!指尖四川麻将多功能开挂攻略,指尖四川麻将确实是有开挂攻略指尖四川麻将脚本下载中分为...
一秒答解透视器技巧!福建众娱多... 一秒答解透视器技巧!福建众娱多功能透视器技巧,福建众娱都是真的是有透视器技巧1、点击下载安装,福建众...
玩家必看科普透视挂方法!良人麻... 玩家必看科普透视挂方法!良人麻将多功能透视挂方法,良人麻将确实存在有透视挂方法1、良人麻将辅助软件下...