You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Apache Beam中在非KV类型PCollection上使用Timer的问题咨询

Apache Beam中在非KV类型PCollection上使用Timer的问题咨询

大家好,我目前在做一个基于Flink运行的Apache Beam作业,需求里需要用到Timers和State功能。

我本来参考了Beam官方的一篇关于及时处理的教程来实现,结果运行时却抛出了错误,提示说timers, states can be used only on KV pairs。但我注意到那篇教程里的示例并没有使用KV类型的PCollection,这就让我有点困惑了——是不是我哪里漏看或者理解错了?有没有办法不用把我的PCollection里的元素转换成KV对,就能正常使用Timers呢?

备注:内容来源于stack exchange,提问作者vamsi

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.04.16 10:40:31