我一般理解事件时间使用水印及时取得进展。对于更多基于迭代的 Flink Statefun 来说,这可能是个问题。所以我的问题是如果我使用延迟消息(https://nightlies.apache.org/flink/flink-statefun-docs-stable/docs/sdk/java/#sending-delayed-messages),那么这是否意味着我们可以在有状态函数中仅使用处理时间概念吗?
我想更改为事件时间处理模型,但不确定它如何与有状态函数一起使用。
pipeline.time-characteristic: EventTime
pipeline.auto-watermark-interval: 200
有人可以解释一下吗?