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
相关产品推荐
相关产品推荐

