英文: Beam stateful timer creates window? 问题 我们有一个处理流水线，它会根据全局窗口中的键元素执行处理（直到某个时点）。 在初始步骤和映射之后，我们有一个有状态...
57评论apache-beam
streaming
Beam stateful timer 创建窗口？
57评论apache-beam
streaming
57评论apache-beam
streaming
将Apache Beam的行转换为Java DataFlow管道中的BigQuery TableFlows该怎么做？
英文: How can I convert Apache Beam Rows to BigQuery TableFlows in a Java DataFlow pipeline? 问题 我需要使用J...
56评论apache-beam
google-bigquery
在GCP BigQuery中自动添加当前时间戳到行插入操作中
英文: Automatically Adding Current Timestamp on Row Insertion in GCP BigQuery 问题 我正在寻求有关在Google Cloud ...
70评论google-cloud-platform
java
How can authenticate in dataflow + Apache beam using Java or Kotlin if I have the content of the service account in the variable?
英文: How can authenticate in dataflow + Apache beam using Java or Kotlin if I have the content of the...
58评论google-cloud-platform
kotlin
我如何在BEAM工作节点上使用Log4j2日志记录？
英文: How can I use Log4j2 logging on BEAM workers? 问题 I'm trying to use Log4j2 logging implementation...
74评论apache-beam
log4j2
想要通过使用Apache Beam在管道中过滤事件来动态命名和创建表格？
英文: Wanted to dynamically name and create tables by filtering events in a pipeline using Apache Beam...
68评论google-cloud-platform
python
为什么下面的Apache Beam代码返回不同的输出？
英文: Why below apache Beam code return different output? 问题 使用yield语句时，SplitWords函数会生成一个迭代器，该迭代器包含所有从...
144评论apache-beam
python
Apache Beam 中的 PubSubIO 写操作是否有 setDelayThreshold() 命令？
英文: Is there setDelayThreshold() command for PubSubIO write in Apache Beam? 问题 是否有在Apache Beam中设置批量P...
59评论apache-beam
google-cloud-dataflow
Apache Beam Elastic IO 模块是否支持通过文档ID对现有文档进行更新？
英文: Does Apache Beam Elastic IO module support updates to existing documents by Id? 问题 Apache Beam是否...
59评论apache-beam
elasticsearch
KeyError 即使步骤没有输入且针对匹配情况存在键。
英文: dataflow python - KeyError even though no input to the step and the key exists for matched cases...
72评论apache-beam
python
7