回答情况：
提问时间：
问题标签：
我跑我得到了然后我跑了pip listapache-beam 2.2.0 python -m apache_beam.examples.wordcount --output cout TheApache Beam SDK for Pytho
浏览 0提问于2019-01-27得票数 0
回答已采纳
pipeline_options = PipelineOptions() custom_options = pipeline_options.view_as(CustomOptions)
p
| beam.Cre
浏览 10修改于2020-05-28得票数 1
回答已采纳
我正在尝试在GCP代码库上运行数据科学中的代码，并不断地在Beam代码中遇到错误。这是给出错误的行: beam.Read(beam.io.TextFileSource('airports.csv.gz')
下面是我得到的错误: AttributeError：'module‘对象没有'
浏览 16提问于2017-02-24得票数 0
我注意到的一件事是，使用beam.Map和beam.ParDo时的结果不同。在第二个例子中，我直接使用beam.Map来做同样的事情，然后打印它。/input/data.csv')| 'Group it 01' >> beam
浏览 1修改于2019-05-22得票数 14
回答已采纳
我一直试图让与Python和Apache一起工作，但我似乎找不到一套完整的指令来使环境正常工作。是否有任何具有完整的先决条件和步骤列表的引用来使一个简单的python管道工作？
浏览 1修改于2021-06-14得票数 3
回答已采纳
我需要在SD卡上创建一个文件夹"BEAM“，但它告诉我无法创建该文件夹。我使用了以下代码： / / Create a folder if not existsmediaDir.exists()) { }
文件夹"beam
浏览 0修改于2013-03-15得票数 0
回答已采纳
1回答
是否可以在Beam中应用嵌套查询？我试图在Beam中运行这样的查询，但得到了错误。(BeamSql.java:116) at org.apache.beam.sdk.Pipeline.applyTransform(Flatten.java:101)
at org.apache.beam.sdk.Pipeline.applyInternal(Pipelin
浏览 1提问于2018-01-19得票数 0
回答已采纳
NFC: S-beam和Android beam有什么区别？有人能解释一下Wifi/蓝牙激活和传输数据的确切流程吗？
浏览 0提问于2013-03-11得票数 12
下面是一个最小的例子：package com.mycompany.beam.hdfsIOIssue;
import org.apache.beam.sdk.io.hdfs.HadoopFileSystemOptions;import org.apache.beam.sd
浏览 1提问于2018-11-03得票数 1
当使用Beam对两个表进行连接时，它正常工作，提供了预期的性能，但是随着我的连接表的增加，性能就变得最差了。任何更好的方法，我可以在Beam
浏览 2修改于2021-06-14得票数 0
回答已采纳
我正在使用apache beam向gcs编写一个json。相同的代码如下： class WriteDataGCS(beam.PTransform): To write data to GCS """
(pcoll | "print intermediate" >> b
浏览 20提问于2019-09-11得票数 0
回答已采纳
我正在使用Google Cloud平台上的AI平台Jupyter Notebook环境(用于Python3的Apache Beam2.28.0)开发Apache Beam管道。as beamfrom google.cloud import storagefrom apache_beam.transforms.ptransform import PT
浏览 3修改于2021-03-04得票数 1
package com.striiv.dataflow;
import org.apache.beam.sdk.testing.PAssert;import org.apache.beam.sdk.transforms.Create;
importorg.apache.beam.sdk.transforms.DoFn
浏览 12提问于2020-10-31得票数 0
回答已采纳
with beam.Pipeline(options=pipeline_options) as p: | 'Readfrom PubSub' >> beam.io.ReadFromPubSub(
浏览 2修改于2020-06-20得票数 2
我正在运行这个beam tutorial的简化版本，但是在我的本地机器上使用DirectRunner运行它。import apache_beam as beamimport os
rows = (p | beam.Row
浏览 29提问于2021-09-01得票数 0
回答已采纳
我一直在使用Go Beam (v2.13.0)，但无法让在GCP数据流上工作。它在尝试启动org.apache.beam.runners.dataflow.worker.DataflowRunnerHarness时进入崩溃循环。(CodedInputStream.java:2424)
at org.apache.beam.model.pipeline.v1.RunnerApi$Coder.at org.apache.beam.model.pipeline.v1.RunnerApi$Coder$Builder.mergeF
浏览 167修改于2019-07-18得票数 1
下面是我的代码：from apache_beam.options.pipeline_options import PipelineOptionsclass ToLower(beam.DoFn): #return [{'Data': element.lower()}]
class ToReverse(<em
浏览 3提问于2020-03-16得票数 1
我想知道是否有可能通过Apache光束在BigQuery中创建一个视图，如果可以，它不在文档https://beam.apache.org/documentation/io/built-in/google-bigquery
浏览 9提问于2021-08-20得票数 0
我试图在安卓手机(Galaxy + S2 )和PN532之间建立联系。这种通信工作良好，我可以在两个方向上传输数据。但现在，发送的信息是我在游戏商店的应用地址.我在NDEF消息中收到两个NDEF记录：
第二种: TNF =绝对URI类型= "android.co
浏览 1修改于2013-04-05得票数 1
回答已采纳
基本上，我查看了现有的IO，发现只有在添加以下内容时，写入才能正常工作：y := beam.GroupByKey(s, x)
在中有一个完整的示例我也检查了BEAM-3860的问题，但没有更多的细节。
浏览 10修改于2021-06-15得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号