我有自定义对象：，我通过 Avro 提供了编码器：，。CustomKeyCustomValueCustomKeyCoderCustomValueCoder 由于我需要按 KV[CustomKey， ...

我有一个简单的处理作业，我想将其作为数据流作业提交。它只是一个 python 文件，它将 csv 作为输入，将两个模型应用于输入，并将输出添加到 csv。如何将其作为 Dataflow 作业提交？我可...

我正在尝试将 XML 文件读入 Apache Beam 管道。某些元素具有命名空间，并且命名空间声明在根节点上声明。我能够使用标准的 JAXB 解析器解析 Apache Beam 之外的 xml。但是...

目前，python Apache Beam SDK for BigQuery 中存在一个错误，该错误将 BQ 错误地转换为 BQ 。这似乎已经修复，但我有一种感觉，它可能在预发布中，而不是最新的稳定版...