apache-beam - 第 3 | 开发者交流平台

Apache Beam查找前N个元素Python SDK

英文: Apache Beam Find Top N elements Python SDK 问题我的要求是从一个BQ表中读取数据，进行一些处理，选择基于“score”列的前N行，并将其写入BQ表，...

2023年2月16日71评论

英文: Apache Beam exit pipeline on condition Python SDK 问题我有一个使用 Apache Beam 构建的数据流水线，该管道从 BigQuery 表...

2023年2月10日69评论

英文: Iterate Keys with Values for Beam pipeline 问题在应用 .apply(GroupByKey.create()) 后，我得到类似 PCollectio...

2023年2月6日57评论

英文: Apache Beam Left Join in Go 问题有没有一种简单的方法可以使用Go执行两个PCollections的左连接？我看到SQL连接只能在Java中使用。 package ...

2023年2月2日89评论

英文: Apache Beam Select Top N rows from PCollection in Go 问题我正在为您翻译以下内容：我有一个PCollection，我需要从中选择n个最大...

2023年2月2日97评论

英文: Apache Beam ParDo Filter in Go 问题我是一个Python开发者，但是现在需要使用Go来创建一个Dataflow流水线。相比Python或Java，我发现很难找到...

2023年2月1日100评论

英文: Reading GPKG format file over Apache Beam 问题 Q1: 哪个Beam库可以帮助我加载geopackage文件？ Q2: 作为备选方案，我正在尝试将ge...

2023年1月9日115评论

英文: Apache Beam Write PubSub messages using Go 问题我是你的中文翻译助手，以下是翻译好的内容：我是Go的新手，尝试从BigQuery读取表格，并使用P...

2022年12月11日87评论

英文: Transmitting global data, or run-specific data, to a Beam DoFn in go 问题我正在为一个流式数据流管道编写一个Go的Beam...

2022年10月20日102评论

英文: Read Google Cloud Pubsub message and write to BigQuery using Golang 问题我正在使用以下代码从Google Cloud Pu...

2022年9月14日102评论